kafka-exactly-once

Kafka-exactly-once是一种消息传输协议，旨在确保在分布式系统中的消息传递具有原子性和一致性。它通过使用事务日志和消费者组协调器来实现这一目标。当生产者发送消息时，它会将消息写入事务日志，然后将其提交给协调器。协调器会检查所有消费者是否已成功处理该消息，如果所有消费者都已确认，则提交事务日志并释放锁。这样，即使出现故障或网络延迟，也能保证每个消息只被处理一次，从而确保数据的完整性和可靠性。