Kafka v0.9 で最大キュー時間を設定するには?
私の理解では、Kafka プロデューサーはキュー内のメッセージを特定のサイズにバッファリングしてから、キュー内のメッセージをバッチとしてブローカーに送信しようとします。ただし、Kafka v0.8 では、"queue.buffering.max.ms" の構成により、メッセージがバッファー サイズよりも小さい場合でも、制限時間に達するとキュー内のメッセージが送信されます。
バッチ処理は、固定された数のメッセージを蓄積しないように構成し、固定された遅延限界 (64k または 10 ミリ秒など) を超えないように構成できます。
Kafka 0.9 ドキュメントから: http://kafka.apache.org/documentation.html#design_asyncsend。(このセクションは Kafka 0.8.2 と同じです)
しかし、v0.9プロデューサー構成セクションで「queue.buffering.max.ms」または同等の構成が見つかりませんでしたhttp://kafka.apache.org/documentation.html#producerconfigs
Kafka v0.9でこれを構成する方法はまだありますか、KafkaProducer.close()それとも電話KafkaProducer.flush()する必要がありますか?