在最新版本的Kafka 0.11.0.0中,Apache团队正在引入幂等生产者和交易.是否可以保证我们想要记录的整组消息(例如100万)只会在最后提交?我想,如果例如生产者放松与经纪人的联系而不能重新安置它,消费者就不会看到消息.可能吗?
transactions atomicity apache-kafka kafka-producer-api
apache-kafka ×1
atomicity ×1
kafka-producer-api ×1
transactions ×1