java——spring boot集成kafka——单播与多播消息的实现

发布时间 2023-03-25 19:27:37作者: 小白龙白龙马

单播消息的实现:

 

 

 

单播消息:⼀个消费组⾥ 只会有⼀个消费者能消费到某⼀个topic中的消息。于是可以创建多个消费者,这些消费者在同⼀个消费组中。

 

 

创建一个消费者,此消费者属于消费组testGroup,获取borker为:10.31.167.10:9092中    主题为test的消息;

 

./kafka-console-consumer.sh --bootstrap-server 10.31.167.10:9092 --consumer-property group.id=testGroup --topic test

 

 

 属于同一消费组中的消费者,同一时刻,只能有一个消费者能获取消息,其他的不能获取。

 

 

 

=======================================================================================

 

 

 

 

创建一个broker:

 

 

 

 

 

 

 

 打开第一个消费者:

 

 

 

 

 

 

 

 打开第二个消费者,2个消费者都属于同一个消费组:

 

 

 

 

 

 

 

 

 

 

 

 

 第二个消费者上线后,第一个消费者就接收不到消息了。(只能接收新的发送消息,之前的接收不到了——同一个消费组)

 

 

 

 

 

 

 

 

 

 

 

 

 =============================================================================