我有一个Kafka主题和一个partiton.when我创建了一个没有提到group.id的组。同一分区有两个不同的使用者。我可以接收消息，我的flink源扩展到flinkkafkaconsumer011。
理想情况下，一个消费者应该收到消息，因为它是同一个组，但在我的情况下，两个消费者都收到消息不知道为什么？？？。
为了测试，我重新启动了一个作业，而新启动的消费者并没有选择它离开的位置，因为其他消费者似乎正在提交补偿。
flink 1.6.0Kafka0.11.2