配置你的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
不会有任何影响,忽视警告。
kafka第一步先获取主题信息,当发现不可用的时候,在去创建主题。
你的答案