关于发布一个不存在的topic时自动创建topic是遇到个警告。修订版本明细

源

采纳

编辑于

江湖浪子

关于发布一个不存在的topic时自动创建topic是遇到个警告。

kafka

配置你的broker，当发布一个不存在的topic时自动创建topic。

我在 https://www.orchome.com/6 的基础上（server.properties，server-1.properties， server-2.properties）追加了以下两个属性

auto.create.topics.enable=true
default.replication.factor=3

使用kafka-console-producer.sh发布消息（当前topic：page_visits_iot4未事先创建），出现警告LEADER_NOT_AVAILABLE，是什么原因？有什么影响吗？

kafka-console-producer.sh --broker-list 192.168.221.136:9092 --topic page_visits_iot4
AAAA1
WARN Error while fetching metadata with correlation id 0 : {page_visits_iot4=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
WARN Error while fetching metadata with correlation id 1 : {page_visits_iot4=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
BBBB1

预览