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
