我有在活动活动站点中维护消息的业务需求，我计划使用kafka。生产者将消息放入 JMS/MQ，将由 KAFKA 使用。那么当生产者将 100 万条消息的批处理消息放入 MQ/JMS 时，是否可以在地理分布式的双活 kafka 集群中维护消息序列？
(假设我们有一个分区，每个主题一个消费者(
提前致谢
是的
，将保留主题的每个分区的消息顺序。在不同的主题之间没有保证。因此，如果您的整个批次由一个生产者发送到同一个单分区主题，是的，订单将被保留。您应该注意配置的一些细微差别，例如，如果每个连接的最大飞行请求数> 1 并且启用了重试，则排序保证将不成立。但是，默认值是安全的。有关更多详细信息，请在 https://kafka.apache.org/documentation/#configuration 中查找"max.in.flight.requests.per.connection">
如果您的设置具有故障转移的冗余生产者，则可能需要考虑启用幂等性。