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) 个答案