有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java Spring Kafka onMessage收到重复消息

我们正在使用卡夫卡1.0.0。M2使用Spring时,我们看到侦听器onMessage()方法接收到许多重复消息。 我们配置了:

enable.auto.commit=false
session.timeout.ms=15000


factory.getContainerProperties().setSyncCommits(true);
factory.setConcurrency(5);

那么,收到重复消息的原因是什么呢

此外,我们有不同类型的主题,所以我们会为每个主题创建不同的侦听器,或者为所有主题创建一个侦听器


共 (0) 个答案