Можно ли редактировать значения после инициализации потребителя Kafka? (из org.apache.kafka.clients.consumer)

#java #spring #apache-kafka

#java #весна #apache-kafka

Вопрос:

Я хотел бы знать, можно ли редактировать значения, которые я дал при создании потребителя Kafka позже, а именно:

 public Consumer<String, String> createCons(){
  final Properties props = new Properties();
  props.put(ConsumerConfig.GROUP_ID_CONFIG, "myId")
  props.put...
  Consumer cons = new KafkaConsumer(props)
  return cons
}

Можно ли редактировать значения (в частности, groupId) моих consumer cons после его создания? Я хотел бы проверить изменения в groupId

Пример:

 cons.setGroupId("newId")

Я просмотрел документы, но там нет ответа. Я предполагаю, что это может быть связано с тем, как ведет себя класс Properties, и что на самом деле редактировать невозможно..

Спасибо!

1. Это невозможно сделать, и речь идет не о свойствах класса, мы всегда можем их редактировать. Именно так разработан KafkaConsumer.

2. Почему идентификатор группы все равно будет меняться во время выполнения?

Ответ №1:

Невозможно изменить конфигурацию экземпляра потребителя после его создания.

Если вам нужна другая конфигурация, вам необходимо создать новый экземпляр клиента.