2015-11-11 19 views
1

我正在使用Kafka 0.8.2。由於這份文件說:卡夫卡經紀人是否爲每封郵件或每批消息發送ACK?

batch.num.messages指定:

消息的數目使用異步模式時,在一個批次發送。生產者將等待,直到這個數量的消息準備發送或達到queue.buffer.max.ms。

and request.required.acks控制經紀人確認請求。

我想知道卡夫卡經紀人如何發送此確認信息,它是否爲該批次或每條消息發送ACK?

回答

2

http://www.slideshare.net/miguno/apache-kafka-08-basic-training-verisign(滑板83):

消息的原始列表基於它們的目的地分區/主題分配(隨機如果使用默認 分割),即 分成較小的批量。每個分割後的批次被髮送到各自的 前導經紀人/ ISR(單獨的send()的發生順序 ),並且每個由其相應的領導者經紀人 根據request.required.acks ACKED

相關問題