}
@Bean
- public EndlessConsumer<String, Message> endlessConsumer(
+ public EndlessConsumer endlessConsumer(
RecordHandler recordHandler,
ApplicationErrorHandler errorHandler,
KafkaProperties kafkaProperties,
KafkaListenerEndpointRegistry endpointRegistry)
{
return
- new EndlessConsumer<>(
+ new EndlessConsumer(
kafkaProperties.getClientId(),
endpointRegistry,
errorHandler,