kafka消费者API

原创
半兽人 发表于: 2016-05-23   最后更新时间: 2023-07-31 23:21:42  
{{totalSubscript}} 订阅, 54,396 游览

随着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.5.1</version>
</dependency>

如何使用新的消费者,请点击这里

更新于 2023-07-31

孙悟空 5年前

你好 我想咨询一下 就是用代码连接kafka  现在有两个消费者 在同一个组下面  不知道为什么老是两个消费者每次都可以消费同一条消息  我想让两个消费者分开消费 比如a消费者消费a消息 b消费者消费b消息  

半兽人 -> 孙悟空 5年前

同一个组下是平分消息,不会重复消费的。

先用官方的代码做测试,测试通过后,在增加逻辑。
如果还不行,到问题专区发个问题,带上你的消费者代码。

孙悟空 -> 半兽人 5年前

我是用的官方的sdk  不过我是c#的  不知道有人知道吗

查看kafka更多相关的文章或提一个关于kafka的问题,也可以与我们一起分享文章