考虑到Producer.end()方法返回的是Future，那么紧接着执行future.get()是否也会阻止记录的批处理？
xpcnnkqh1#
它阻塞以刷新记录的缓冲区，并等待生产者的任何配置的ACK。
KafkaProducer是线程安全的，因此在非阻塞线程中调用send应该可以，但可能会导致无序事件。
KafkaProducer
send
否则，是的，您可以根据需要多次调用Send来批处理数据，而不是Get the First Future。
1条答案
按热度按时间xpcnnkqh1#
它阻塞以刷新记录的缓冲区，并等待生产者的任何配置的ACK。
KafkaProducer是线程安全的，因此在非阻塞线程中调用send应该可以，但可能会导致无序事件。否则，是的，您可以根据需要多次调用Send来批处理数据，而不是Get the First Future。