如何创建kafka consumer

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了如何创建kafka consumer相关的知识,希望对你有一定的参考价值。

参考技术A 情况是这样的,在我们系统中有多个Consumer的客户端(客户端个数是不确定的,因为在系统工作过程中有的业务节点会脱离,有些业务节点会增加进来),Producer也有多个。但是Producer发送的消息种类只有一种,所以topic只创建了一个, 消息量很大,所以使用了多个Consumer来处理。现在想实现如下的订阅/推送效果,多个Producer进行消息的推送,例如消息X1、X2、X3、X4、X5.。。。。。。然后由多个Consumer分别进行拉去,Consumer1拉取到:X1、X4、X7。。。Consumer2拉取到:X2、X5、X8.。。。。。。。。如此类推

以上是关于如何创建kafka consumer的主要内容,如果未能解决你的问题,请参考以下文章

如何在kafka中创建topic

010 消费者消费消息API

如何从kafka主题为ksqldb创建主题

2、kafka如何选定分区数量

如何在使用 Spring 创建期间配置 kafka 主题保留策略?

一文弄懂如何创建并使用Kafka生产者