У меня есть тема Кафки и один раздел. Когда я создаю потребителя, упускается упоминание группы .id. Есть 2 разных потребителя для одного раздела.
Я могу получать сообщения, и мой источник flink расширяет FlinkKafkaConsumer011.
В идеале один потребитель должен получать сообщение, поскольку это одна и та же группа, но в моем случае оба потребителя получают сообщения, не зная, почему ???.
Для проверки перезапустил одну из моих работ, и вновь начатый потребитель, кажется, не выбирает, где он ушел, потому что другой потребитель совершает смещение, кажется.
Flink 1.6.0
Кафка 0.11.2