Я создаю ПО C, которое содержит кластер Kafka, развернутый в Kubernetes, и три приложения с весенней загрузкой, которые читают из kafka и пишут в jms и наоборот.
Я хочу знать, как обеспечить целостность данных и согласованность обеспечивается, например: если узлу производителя не удалось, как потребитель собирается продолжить чтение сообщения без потери согласованности сообщения. Есть ли подробный сценарий для тестирования этой функции.