0
假設,我有一個消費者訂閱了多個主題。 當我進行民意調查時選擇了哪個主題? 我正在爲客戶端使用RdKafka .Net。有什麼方法可以影響,選擇了哪個主題?卡夫卡消費者如何選擇接下來輪詢哪個主題?
假設,我有一個消費者訂閱了多個主題。 當我進行民意調查時選擇了哪個主題? 我正在爲客戶端使用RdKafka .Net。有什麼方法可以影響,選擇了哪個主題?卡夫卡消費者如何選擇接下來輪詢哪個主題?
消費者對所有主題分區進行輪詢(未暫停)。經紀人決定要返回哪些數據。你不能直接影響經紀人的行爲。
不確定是否RdKafka
有一個API來暫停和恢復分區。我現在只有Java KafkaConsumer
,提供方法#pause()
和#resume()
。