c# kafka 消费者重复消费

孙悟空 发表于: 2018-06-22   最后更新时间: 2018-06-22 19:23:58   3,602 游览

我是用的是c#语言进行kafka客户端连接的,现在遇到的问题就是多个消费者在同一个消费组下面 但是两个消费者会获取到同一个消费信息
我是用winform做了一个exe 所以我理解的消费者就是把这个exe运行两次 不知道这样理解对不对 还是说不管这个exe运行多少次都是一个消费者
consumer代码
screenshot
Producer代码
screenshot

希望各位大佬看看有什么问题 还是我理解错误了!运行一次exe不就是单独启动一个进程吗?这个进程不就算一个消费者吗?还是说每个消费者还得多传递一个参数 用来区分

发表于 2018-06-22
添加评论

楼主有解决问题吗?

组名是相同的 也是手动提交的offset

半兽人 -> 孙悟空 5年前

你自动提交关了吗?

孙悟空 -> 半兽人 5年前

嗯 这个关了

半兽人 -> 孙悟空 5年前

那我帮不了你了,如果group.id一致,那么引起重复的就是 自动和手动同时启用了。

孙悟空 -> 半兽人 5年前

哎 郁闷  不知道是不是代码的问题 我正在研究java的 打算用java的跑一下看看是不是也是这样

你的答案

查看kafka相关的其他问题或提一个您自己的问题