单播消息的实现:
单播消息:⼀个消费组⾥ 只会有⼀个消费者能消费到某⼀个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个消费者都属于同一个消费组:
第二个消费者上线后,第一个消费者就接收不到消息了。(只能接收新的发送消息,之前的接收不到了——同一个消费组)
=============================================================================
标签:多播,消费,java,消费者,--,spring,kafka,单播,消息 From: https://www.cnblogs.com/xiaobaibailongma/p/17255409.html