java - Kafka 消费者如何选择下一个要轮询的主题?

标签 java .net apache-kafka messaging

假设,我有一个消费者订阅了多个主题。 当我进行民意调查时,选择了哪个主题? 我正在为客户端使用 RdKafka .Net。有什么方法可以影响选择哪个主题?

最佳答案

消费者对所有主题分区(未暂停)进行轮询。经纪人决定返回什么数据。您不能直接影响经纪人的行为。

不确定 RdKafka 是否有暂停和恢复分区的 API。我现在只使用 Java KafkaConsumer,它提供方法 #pause()#resume()

关于java - Kafka 消费者如何选择下一个要轮询的主题?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41981609/

相关文章:

java - Thymeleaf - 使用条件设置属性值

java - IntelliJ 在鼠标悬停时显示 JavaDocs 工具提示

c# - 添加 LINQ 的 LongCount 扩展方法是否有实际原因?

scala - 在 zeppelin notebook 中保存 Spark 流消耗的 kafka 消息

ruby - Ruby Kafka未捕获的异常:未能找到组协调器

java - 为什么 Java 中的复合赋值没有捕获溢出问题?

java - 使用或不使用 GAE 存储超过 500 个字符的字符串/文本值

.net - Lazy<T> 有空版本吗?

.net - 为什么我会得到 "The type of namespace name ' bla' does not exist...” 没有更改后?

docker - 如何配置 docker-compose 以便将磁盘挂载到文件夹,而不是本地磁盘