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