Hi Suraj,
This question has been asked before:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-kafka-consumers-don-t-honor-group-id-td21054.html
Best,
Gary
On Wed, Apr 22, 2020 at 6:08 PM Suraj Puvvada <su...@traceable.ai> wrote:
>
> Hello,
>
> I have two JVMs that run LocalExecutionEnvorinments each using the same
> consumer group.id.
>
> i noticed that the consumers in each instance has all partitions assigned. I
> was expecting that the partitions will be split across consumers across the
> two JVMs
>
> Any help on what might be happening ?
>
> Thanks
> Suraj
