kafka笔记
时间:2019-07-14 23:45:55
收藏:0
阅读:169
- 首先搭建kafka和zookeeper,找帖子
搭建时需要注意
其次,保证zookeeper是集群环境,也可以代建伪集群,不然启动不起来报:
partitions have leader brokers without a matching listener。 -
一个生产者的消息如果没有key值,则会随机到每个分区,
搭建时出了个问题,因为kafka配置文件默认partition为1,所以在我本地两个消费者始终有一个消费者消费不到消息,
后面改完配置文件分区设置2个,but 没起作用,依然只有一个消费者能消费到消息
各种查。。。网上也是都在说topic会发送到不同的partition,不同的partition会对应不同的消费者,吴国。。。
后面在生产者新建一个topic_b 然后好了,看来是一个topic在生成时就会有一些操作来对应partition,后面在查阅。 - 卡夫卡是真的快。
- 会继续更新。
原文:https://www.cnblogs.com/imaye/p/11186459.html
评论(0)