У меня следующая конфигурация:
- Одна кафка-топик с 2-мя разделами
- Один экземпляр zookeeper
- Один экземпляр кафки
- Два потребителя с одинаковым идентификатором группы
Фрагмент вакансии Flink:
speStream.addSink(new FlinkKafkaProducer011(kafkaTopicName,new
SimpleStringSchema(), props));
Сценарий 1:
Я написал задание flink (Producer) на eclipse, которое читает файл из папки и помещает сообщения в тему kafka.
Поэтому, когда я запускаю этот код с помощью eclipse, он отлично работает.
Например: Если я помещаю файл со 100 записями, flink отправляет несколько сообщений в раздел 1 и несколько сообщений в раздел 2, и, следовательно, оба потребителя получают несколько сообщений.
Сценарий 2: Когда я создаю банку с приведенным выше кодом и запускаю ее на сервере flink, flink отправляет все сообщения в один раздел, и, следовательно, только один потребитель получает все сообщения.
Мне нужен сценарий 1 с использованием банки, созданной в сценарии 2.