kafka测试同一个消费组的多个消费者负载均衡实例(集成spring)

这里使用的是zookeeper和kafka3台机器的集群,这样能保证如过有一台机器炸了还能运行,在集群环境中,要在kafka的 server.properties中配置zookeeper集群地址等信息,最重要的是num.partitions=3.这样一个分区就是一个机器,所以当kafka发消息的时候就会发送到每个机器上。 就是因为这个才踩到一个坑,集群配置好了,创建topic设置了3个分区,2个备
相关文章
相关标签/搜索