f1s*_*rox 1 apache-kafka kafka-consumer-api
如果我创建一个消费者C1与组consumerGroup从主题读取数据A。不久之后C2,在同一组中创建消费者,以从topic中读取数据B。
创造消费者会C2引发再平衡吗?作为一个更普遍的问题,kafka何时会执行重新平衡?
每次新消费者加入该组或消费者离开该组(通过呼叫close()或通过超时主动)时,都会触发重新平衡。
此外,如果您订阅尚未创建的主题,则在创建该主题后将触发重新平衡。同样,如果您订阅的主题被删除。同样,如果任何已订阅主题的分区数已更改。最后但并非最不重要的一点是,如果您通过模式进行预订,如果新主题与模式匹配或匹配的主题被删除,或者任何匹配主题的分区数都发生了更改,则会发生重新平衡。
参见https://cwiki.apache.org/confluence/display/KAFKA/Kafka+0.9+Consumer+Rewrite+Design
| 归档时间: |
|
| 查看次数: |
1677 次 |
| 最近记录: |