myt*_*hic 13 apache-kafka kafka-consumer-api kafka-topic
假设我有一个大约有 10 个分区的 kafka 主题,我知道每个消费者组应该有 10 个消费者在任何给定时间从该主题中读取数据,以实现最大并行度。
然而,我想知道对于一个主题在任何给定时间点可以处理的消费者组的数量是否也有任何直接的规则。(最近在一次采访中我被问到了这个问题)。据我所知,这取决于代理的配置,以便它在任何给定时间点可以处理多少个连接。
但是,只是想知道在给定时间点可以扩展多少个最大消费者组(每个消费者组有 10 个消费者)?
从概念上讲,您可以将消费者组视为恰好由多个进程组成的单个逻辑订阅者。作为一个多订阅者系统, Kafka 自然支持给定主题拥有任意数量的消费者组 ,而无需复制数据(额外的消费者实际上相当便宜)。
正如 Kafka 0.9 的 API 文档中给出的那样,Kafka 可以支持给定主题的任意数量的消费者组。
链接:http://kafka.apache.org/090/javadoc/index.html?org /apache/kafka/clients/consumer/KafkaConsumer.html
| 归档时间: |
|
| 查看次数: |
11471 次 |
| 最近记录: |