Я хочу ускорить мой процесс с группой потребителей 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
Я ожидал, что клонированные приложения (с одинаковым идентификатором) и с другим идентификатором группы будут запускать одну и ту же тему с общими разделами
Большое спасибо за помощь экспертов.