在kafka集群中有一个具有8个分区的主题。我用kafkamessagedrivenchanneladapter实现了一个应用程序来使用这个主题，这个应用程序并发的是8，offsetmanager是kafkatopicoffsetmanager。当我启动一个应用程序示例时，一切都正常。但是当我启动两个应用程序示例时，我发现meesge被消耗了两次。你知道为什么，怎么解决吗？我需要换成高级消费者？
rjee0c151#
您必须使用该适配器跨示例分布分区。我们正在努力升级到kafka0.9java客户机，它支持消费群体。核心项目的第一个里程碑是可用的。我们需要致力于发布使用这个新客户机的SpringIntegrationKafka2.0的里程碑。
1条答案
按热度按时间rjee0c151#
您必须使用该适配器跨示例分布分区。
我们正在努力升级到kafka0.9java客户机，它支持消费群体。
核心项目的第一个里程碑是可用的。
我们需要致力于发布使用这个新客户机的SpringIntegrationKafka2.0的里程碑。