2017-02-01 56 views

回答

1

消費者對所有主題分區進行輪詢(未暫停)。經紀人決定要返回哪些數據。你不能直接影響經紀人的行爲。

不確定是否RdKafka有一個API來暫停和恢復分區。我現在只有Java KafkaConsumer,提供方法#pause()#resume()