假设,我有一个消费者订阅了多个主题。 当我进行民意调查时,选择了哪个主题? 我正在为客户端使用 RdKafka .Net。有什么方法可以影响选择哪个主题?
最佳答案
消费者对所有主题分区(未暂停)进行轮询。经纪人决定返回什么数据。您不能直接影响经纪人的行为。
不确定 RdKafka
是否有暂停和恢复分区的 API。我现在只使用 Java KafkaConsumer
,它提供方法 #pause()
和 #resume()
。
关于java - Kafka 消费者如何选择下一个要轮询的主题?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41981609/