当前版本的kafka是否支持producer.type配置？我在文档中没有看到producer.type配置属性。但是，存在与批处理相关的配置属性。为什么会这样？所有生产者现在都是异步的吗？或者他们删除了生产者的异步行为？
azpvetkf1#
生产者是异步的，因为他们返回一个未来，您可以等待未来在您的代码中完成，然后再发送下一条消息以实现同步行为，当然，假设ack设置为大于零。
1条答案
按热度按时间azpvetkf1#
生产者是异步的，因为他们返回一个未来，您可以等待未来在您的代码中完成，然后再发送下一条消息以实现同步行为，当然，假设ack设置为大于零。