StringJsonMessageConverter
works well with Message<PO>
as method parameter when using @KafkaListener
, but doesn't work with List<Message<PO>>
in batch listener mode. Already set factory.setMessageConverter(new BatchMessagingMessageConverter(jsonMessageConverter));
.
It seems that the listener does not using StringJsonMessageConverter
to convert each record when the message parameter isMessageList
.