随着0.9.0版本,我们已经增加了一个新的Java消费者替换我们现有的基于zookeeper的高级和低级消费者。这个客户端还是测试版的质量。为了确保用户平滑升级,我们仍然维护旧的0.8版本的消费者客户端继续在0.9集群上工作,两个老的0.8 API的消费者( 高级消费者 和 低级消费者)。
这个新的消费API,清除了0.8版本的高版本和低版本消费者之间的区别,你可以通过下面的maven,引入依赖到你的客户端。
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>3.7.0</version>
</dependency>
如何使用新的消费者,请点击这里。
你好 我想咨询一下 就是用代码连接kafka 现在有两个消费者 在同一个组下面 不知道为什么老是两个消费者每次都可以消费同一条消息 我想让两个消费者分开消费 比如a消费者消费a消息 b消费者消费b消息
同一个组下是平分消息,不会重复消费的。
先用官方的代码做测试,测试通过后,在增加逻辑。
如果还不行,到问题专区发个问题,带上你的消费者代码。
我是用的官方的sdk 不过我是c#的 不知道有人知道吗