Kafka 消费者如何选择下一个要轮询的主题?
How does a Kafka consumer choose from which topic to poll next?
假设,我有一个消费者订阅了多个主题。
当我进行民意调查时,选择了哪个主题?
我正在为客户端使用 RdKafka .Net。有什么方法可以影响选择哪个主题?
消费者对所有主题分区(未暂停)进行轮询。经纪人决定要 return 的数据。您不能直接影响经纪人的行为。
不确定 RdKafka
是否有 API 来暂停和恢复分区。我现在才 Java KafkaConsumer
,提供方法 #pause()
和 #resume()
.
假设,我有一个消费者订阅了多个主题。 当我进行民意调查时,选择了哪个主题? 我正在为客户端使用 RdKafka .Net。有什么方法可以影响选择哪个主题?
消费者对所有主题分区(未暂停)进行轮询。经纪人决定要 return 的数据。您不能直接影响经纪人的行为。
不确定 RdKafka
是否有 API 来暂停和恢复分区。我现在才 Java KafkaConsumer
,提供方法 #pause()
和 #resume()
.