使用批处理异步生产者时,kafka如何发送确认?ack是每个消息/每批次/每个子批次(即每个分区的批次)?是否建议在异步批处理prdocuer中使用ack?或者更好的只是使用回调机制?
apache-kafka kafka-producer-api
apache-kafka ×1
kafka-producer-api ×1