apache-kafka - kafka 在重启时丢失所有主题

标签 apache-kafka

我正在 VM 中试用 Kafka (0.8.2.1),但遇到了问题:尽管在机器保持开启时一切正常(即使我重新启动 ZK/Kafka),如果我重新启动机器(在正常关闭后)关闭 ZK/Kafka)似乎所有 Kafka 主题都丢失了。

我可能在这里遗漏了一些基本的东西,因为这可能不应该发生。可能是什么?

cd /vagrant/kafka_2.11-0.8.2.1
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 10 --topic foo
bin/kafka-topics.sh --list --zookeeper localhost:2181
# foo
# ^C then resume ZooKeeper, Kafka, or both
bin/kafka-topics.sh --list --zookeeper localhost:2181
# foo
# ^C both, reboot machine, boot ZK/Kafka again
bin/kafka-topics.sh --list --zookeeper localhost:2181
# no topics

最佳答案

看起来日志的默认位置在/tmp 目录中,该目录在重新启动时会被删除。将配置中的该位置更改为更永久的位置。

关于apache-kafka - kafka 在重启时丢失所有主题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32437415/

相关文章:

jdbc - Apache Kafka JDBC 连接器 - SerializationException : Unknown magic byte

apache-kafka - 通过 Java API 获取和更新 Kafka 主题配置

apache-spark - Spark 流: ERROR StreamingContext: failed to construct kafka consumer

docker - OpenShift - 创建新应用程序时何时创建服务?

python - 如何在融合的kafka python中读取批处理消息?

asp.net - Dockerized Asp.net Core 无法连接到 WSL 中主机的 Kafka

docker - Kafka stream.allMetadata()在DOCKER中返回空列表(交互式查询)

kubernetes - K8s 上广告的 kafka 连接休息监听器

go - 覆盖现有的 golang 结构并添加字段

java - 如何查找Kafka主题中第一条未删除的消息