Метод слушателя Spring Kafka - запись входной записи

Question

Я использую spring-kafka, а мой метод @KafkaListener имеет аргумент, помеченный @org.springframework.messaging.handler.annotation.Payload, как показано ниже:

@KafkaListener(topics = "my-topic")
public void consumeTrigger(@Payload InputDTO InputDTO) {
   ...
}

Входные данные находятся в формате json, и я использую org.springframework.kafka.support.serializer.JsonDeserializer как значение-десериализатор. Все хорошо, но мне нужно записать полученный ввод json. Есть ли такая возможность spring-kafka, и если нет, есть ли альтернатива, кроме предоставления пользовательского JsonDeserializer?

Answer 1

В десериализаторе в данный момент нет входа в систему; вы можете просто обернуть JsonDeserializer своим собственным и назвать его deserialize() после регистрации; просто не забудьте также делегировать метод configure().