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

江湖浪子 发表于: 2016-05-15   最后更新时间: 2021-09-16 10:20:18   11,081 游览

配置你的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
发表于 2016-05-15
添加评论

不会有任何影响,忽视警告。
kafka第一步先获取主题信息,当发现不可用的时候,在去创建主题。

你的答案

查看kafka相关的其他问题或提一个您自己的问题