Я использую пружину kafka 2.2.2.RELEASE
Наш брокер имеет строгую проверку авторизации.
Вот наша конфигурация клиента:
- spring.kafka.producer.transaction-id-prefix = test.
- topic: topic
- groupId: group
Должен генерироваться транзакционный идентификатор: "test.group.topic0 "
Проблема:
Когда я запускаю приложение, вызывается KafkaMessageListenerContainer # onPartitionsAssigned, а используемый идентификатор транзакции -" test0 ".Похоже, что в этом случае kafkaTemplate не считается в listenerContainer.
Это приводит к неавторизованному исключению, поскольку брокер отклонил этот транзакционный идентификатор
Вопрос
Это нормально?