apache kafka 0.10.0.0 consumer怎么写

2025-05-07 16:51:54
推荐回答(1个)
回答1:

一个partition只能被同一个ConsumersGroup的一个线程所消费.
线程数小于partition数,某些线程会消费多个partition.
线程数等于partition数,一个线程正好消费一个线程.
当添加消费者线程时,会触发rebalance,partition的分配发送变化.
同一个partition的offset保证消费有序,不同的partition消费不保证顺序.