如何在kafka中创建多个消费者来读取来自生产者的相同消息,并在接收到这些消息后对每个消费者执行不同的任务

2cmtqfgy  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(354)

我有一个用例,在这个用例中,我需要创建3个消费者,他们可以从生产者发送的一个或多个分区读取所有消息。我需要我的3个消费者做3个不同的任务后,收到相同的消息。
一个很好的方法是使用
props.put(“group.id”,uuid.randomuuid().tostring())
关于这个想法,我参考了下面的链接。
kafka分区的多个消费者
我很想知道如何通过twick ConsumerGroup示例代码来实现这一点?如何创建多个消费者?收到消息后,我如何分别管理它们?我是否需要创建consumergroupexample的多个对象?

mepcadol

mepcadol1#

是的,您需要创建3个具有不同group.id的对象。
只需注意一点:对每个组使用静态名称(而不是随机名称),以支持故障转移和在多个示例上并行执行同一任务。

相关问题