1. 当kafka consumer的并发大于kafka partition的情况,多余的并发会怎么样?
2. 当kafka consumer并发等于kafka partition个数,但是kafka 
partition个别分区没有数据的情况,这个空的partition的consumer线程会怎么样?对barrier和watermark的生成有什么影响?



[email protected]

回复