如何在kafka中创建持久主题
How to create a durable topic in kafka
我是 kafka 的新手,仍在学习它的基础知识。我想创建一个持久主题,即使在 zoopkeeper and/or kafka 服务器关闭后也会保留该主题。
我注意到这一点 - 我在本地 macbook 上有一个 zookeeper 和 kafka 服务器 运行。当我关闭 zookeeper 服务器并再次快速启动它时,我可以看到之前创建的主题。但是如果我重新启动系统然后重新启动 zookeeper 服务器 - 我看不到我之前创建的主题。
我在本地系统上是 运行 kafka_2.9.2-0.8.1.1。
发生这种情况是因为 /tmp
在重启后被清理,导致您的数据丢失。
要解决此问题,请将 Zookeeper dataDir
属性(在 config/zookeeper.properties
中)和 Kafka log.dirs
(在 config/server.properties
中)修改为不在 /tmp
.
我是 kafka 的新手,仍在学习它的基础知识。我想创建一个持久主题,即使在 zoopkeeper and/or kafka 服务器关闭后也会保留该主题。 我注意到这一点 - 我在本地 macbook 上有一个 zookeeper 和 kafka 服务器 运行。当我关闭 zookeeper 服务器并再次快速启动它时,我可以看到之前创建的主题。但是如果我重新启动系统然后重新启动 zookeeper 服务器 - 我看不到我之前创建的主题。 我在本地系统上是 运行 kafka_2.9.2-0.8.1.1。
发生这种情况是因为 /tmp
在重启后被清理,导致您的数据丢失。
要解决此问题,请将 Zookeeper dataDir
属性(在 config/zookeeper.properties
中)和 Kafka log.dirs
(在 config/server.properties
中)修改为不在 /tmp
.