alive的主页 - OrcHome

半兽人回复 alive 在 kafka同一个消费组的多实例，有一些实例只消费消息，处理完数据后不发出消息到其他Topic。中：

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

 producer.send(record).get();

5年前

alive 回复半兽人在 kafka同一个消费组的多实例，有一些实例只消费消息，处理完数据后不发出消息到其他Topic。中：

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

5年前

半兽人回复 alive 在 kafka同一个消费组的多实例，有一些实例只消费消息，处理完数据后不发出消息到其他Topic。中：

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

5年前

5年前

订阅了 kafka 主题！ · 5年前