Spring Boot внедряет ObjectMapper в Kafka JsonDeserializer

Question

Я хотел бы добавить ObjectMapper Джексона в JsonDeserializer для ConsumerFactory Кафки. Я сделал то, что упоминается в этом посте:

Внедрение ObjectMapper в сериализатор / десериализатор Spring Kafka

Однако, когда у меня есть несколько @KafkaListener на разные темы, ConcurrentKafkaListenerContainerFactory создает несколько экземпляров ConcurrentMessageListenerContainer, используя карту свойств для инициализации ConsumerFactory вместо экземпляра, переданного в ConcurrentKafkaListenerContainerFactory.setConsumerFactory(). Только первый ConcurrentMessageListenerContainer использует правильный ConsumerFactory.

Как это исправить и правильно настроить Kafka?

Answer 1

Вам нужна отдельная фабрика потребителей / контейнеров для каждого слушателя.Затем используйте свойство containerFactory в @KafkaListener, чтобы указать используемую фабрику.