我正在学习kafka CLI。并有一个问题。为什么我们必须使用 - 动物园管理员 </跨度> 创建主题和使用消息时的选项,但是在生成消息时,我们只使用–broker-list,它只是指K卡夫卡本身,1.创造主题
./kafka-topics.sh –create - 动物园管理员 </跨度> docker-machine ip bigdata –rerelication-factor 1 –partitions 1 –topic bigdata
docker-machine ip bigdata
2.产生消息
./kafka
您必须区分主题管理和主题消费。 ZK不仅用于经纪人协调,还用于主题管理。
对于主题管理,ZK用于存储主题元数据和经纪人(目前,Kafka 0.10.1 )不提供主题管理API。因此,管理CLI工具实际上直接与ZK(而不是代理)对话。当新的“管理客户端”完全实施时,这将在未来发生变化(c.f。 https://cwiki.apache.org/confluence/display/KAFKA/KIP-4+-+Command+line+and+centralized+administrative+operations )
0.10.1
对于主题消费,不需要ZK,消费者和生产者客户只与经纪人交谈。