Как настроить клиент Кафка VertX идентификатор запуска того же приложения, но не тот же идентификатор группы на той же теме - PullRequest
0 голосов
/ 27 сентября 2019

Я хочу ускорить мой процесс с группой потребителей kafka vertx.Итак, я хочу иметь несколько копий приложения (один и тот же идентификатор), но эти копии не совпадают с идентификатором группы, слушая одну и ту же тему Кафки.Когда приложения с другим идентификатором группы, они будут назначены для использования различных разделов.

Я использую клиент Vertx Kafka от Java.Вот примеры https://vertx.io/docs/vertx-kafka-client/java/

Я настроил группу потребителей следующим образом:

Map<String, String> config = new HashMap<>();
config.put("bootstrap.servers", "localhost:9092");
config.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
config.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
config.put("group.id", "my_group");
config.put("auto.offset.reset", "earliest");
config.put("enable.auto.commit", "false");

// use consumer for interacting with Apache Kafka
KafkaConsumer<String, String> consumer = KafkaConsumer.create(vertx, config);

, но я не вижу config.put ("app.id", "my_app") Есть какие-либо настройкинастроить app.id?или клиент Vertx kafka не поддерживает app.id

Я ожидал, что клонированные приложения (с одинаковым идентификатором) и с другим идентификатором группы будут запускать одну и ту же тему с общими разделами

Большое спасибо за помощь экспертов.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...