kafka同一个消费组的多实例,有一些实例只消费消息,处理完数据后不发出消息到其他Topic。

alive 发表于: 2020-01-09   最后更新时间: 2020-01-13 22:49:41   2,290 游览

同一个消费组的多实例,有一些实例只消费消息,处理完数据后不发出消息到其他Topic。

  • kafka版本:2.11-0.10.2.0
  • 没有报错信息及日志
发表于 2020-01-09
添加评论

我没明白额,你详细描述一下吧。

alive -> 半兽人 4年前

生产环境上有一个叫A 的topic,同时有一个叫F的消费组,这个消费组有9个实例在消费A的消息,其中有两三个实例 消费了A的消息之后却没有向B topic生产消息。而其他几个实例都有向B topic生产消息。

半兽人 -> alive 4年前

懂了,但是你这个跟你的代码写的有关系,我并不清楚你的业务逻辑,你可以将生产者改成同步发送,这样如果有错误发送,错误就会返回。

 producer.send(record).get();
你的答案

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