特牛网址导航

Kafka3.0 消费者 生产经验_kafka3.0消费者代码-CSDN博客

网友收藏
文章浏览阅读146次。2)Range 分区分配策略案例(1)修改主题 first 为 7 个分区。(2)复制 CustomConsumer 类(CustomConsumer类链接 ),创建 CustomConsumer2。这样可以由三个消费者CustomConsumer、CustomConsumer1、CustomConsumer2 组成消费者组,组名都为“test”,同时启动 3 个消费者。(3)启动 CustomProducer 生产者(CustomProducer普通异步发送即可,随后将循环中的5改成500),发送 _kafka3.0消费者代码