我遇到了以下关于同步发送从生产者。我知道上下文生成器中的异步机制在此将来调用get（）将被阻止，直到相关请求完成，然后返回记录的元数据或引发发送记录时发生的任何异常。什么是真正意义上的相关请求完成，我很清楚这不是指完整的请求，但在何种程度上这句话是指？直到经纪人？直到生产商使用的缓冲液等？当ack=all与同步生产者和异步生产者一起使用时有什么不同？两种情况都被阻止进行确认？
lnlaulya1#
生产者有一个内部队列来缓冲一些记录（基于配置） linger.ms 以及 min.batch.size ). 有一个内部后台线程请求代理（前导分区所在的位置）发送批处理数据。取决于配置 max.connections.in.flight 生产者可以有多个并行请求。这是指“关联请求”。当ack=all与同步生产者和异步生产者一起使用时有什么不同？两种情况都被阻止进行确认？这个 get 方法将阻塞，直到对代理的请求完成，这意味着它收到了基于acks设置的所有确认。使用 get 方法总是导致同步生产者。
linger.ms
min.batch.size
max.connections.in.flight
get
1条答案
按热度按时间lnlaulya1#
生产者有一个内部队列来缓冲一些记录（基于配置）
linger.ms以及min.batch.size). 有一个内部后台线程请求代理（前导分区所在的位置）发送批处理数据。取决于配置max.connections.in.flight生产者可以有多个并行请求。这是指“关联请求”。当ack=all与同步生产者和异步生产者一起使用时有什么不同？两种情况都被阻止进行确认？
这个
get方法将阻塞，直到对代理的请求完成，这意味着它收到了基于acks设置的所有确认。使用
get方法总是导致同步生产者。