Kafka中的消息一致性测试场景

Question

我正在构建一个POC，其中包含一个部署在Kubernetes上的Kafka集群和三个从Kafka读取并写入jms的spring-boot应用程序，反之亦然。

我想知道如何确保数据的完整性和一致性，例如：如果生产者节点失败，消费者将如何在不丢失消息一致性的情况下继续读取消息。是否有详细的场景来测试此功能。

Answer 1

请参阅Spring for Apache Kafka关于事务的文档。

如果你是初来乍到的春天；另请参阅Spring Kafka所利用的Spring Framework的事务支持。

Kafka不能在JTA(XA(事务中进行奇偶校验，因此您唯一的选择是考虑通过Spring事务同步进行Best Affairs 1PC提交，并处理以前处理过的消息(在失败后(重新交付的(小(可能性。