we have spring boot 2.7 + kafka, and can consume messages thusly:

we have spring boot 2.7 + kafka, and can consume messages thusly:

we have spring boot 2.7 + kafka, and can consume messages thusly:

we have spring boot 2.7 + kafka, and can consume messages thusly:

we have spring boot 2.7 + kafka, and can consume messages thusly:

we have spring boot 2.7 + kafka, and can consume messages thusly:

I have a batch listener:

@Configuration public class Config { @Bean public RecordMessageConverter converter() { return new JsonMessageConverter(); } @Bean public BatchMessagingMessageConverter batchConverter() { return new BatchMessagingMessageConverter(converter()); } } @Component @RequiredArgsConstructor public class CancelAuthorizationLinkageListener { private final KafkaTemplate<String, CancelAuthorizationLinkage> kafkaTemplate; @KafkaListener( id = “${spring.kafka.listener.cancel-auth-linkage.id}”, topics = “${spring.kafka.listener.cancel-auth-linkage.topic.linkage}”, autoStartup = “false”, batch = “true”, groupId = “cushion”) public void listen(List<Message<CancelAuthorizationLinkage>> messages) […]

I am trying to set a generic GossiperMessageListener on ConcurrentKafkaListenerContainerFactory like below

I am trying to set a generic GossiperMessageListener on ConcurrentKafkaListenerContainerFactory like below