我使用int-kafka：message-driven-channel-adapter从主题中消费消息，我们有3个不同的较低环境（dev/perf/stage），但所有较低环境的主题都是相同的，所以在我们的情况下，kafka消息被消费和发布三次，因为应用程序部署在这些环境中，所以我们试图添加一个布尔标志，不消费来自其他环境的消息，一次只保持一个env活动？在spring integration int-kafka中，有没有其他方法可以实现这一点：message-driven-channel-adapter？
你能解释一下int-kafka上的auto startup字段吗：message-driven-channel-adapter并将其设置为false将停止从主题中消耗消息（我可能完全错了！）
你能帮帮忙吗
1条答案
按热度按时间hc8w905p1#
如果您的所有环境都连接到同一个中间件，那么它实际上不是环境的分离。您应该考虑为这些示例使用单独的Apache Kafka代理。
是的，
auto-startup="false"意味着这个通道适配器不会自动启动，因此它不会使用主题中的记录。您可以从一个属性占位符解析这个属性，因此每当您需要不启动它时，可以将相应的属性设置为false。但是，这在启动时仅起作用一次：在应用程序运行时对属性文件的更改不会产生任何影响。