我正在构建一个POC，其中包含一个部署在Kubernetes上的Kafka集群和三个从Kafka读取并写入jms的spring-boot应用程序，反之亦然。
我想知道如何确保数据的完整性和一致性，例如：如果生产者节点失败，消费者将如何在不丢失消息一致性的情况下继续读取消息。是否有详细的场景来测试此功能。
请参阅Spring for Apache Kafka关于事务的文档。
如果你是初来乍到的春天；另请参阅Spring Kafka所利用的Spring Framework的事务支持。
Kafka不能在JTA(XA(事务中进行奇偶校验，因此您唯一的选择是考虑通过Spring事务同步进行Best Affairs 1PC提交，并处理以前处理过的消息(在失败后(重新交付的(小(可能性。
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium