}
@Bean
- public EndlessConsumer endlessConsumer(
+ public EndlessConsumer<String, String> endlessConsumer(
KafkaConsumer<String, String> kafkaConsumer,
ExecutorService executor,
Consumer<ConsumerRecord<String, String>> handler,
ApplicationProperties properties)
{
return
- new EndlessConsumer(
+ new EndlessConsumer<>(
executor,
properties.getClientId(),
properties.getTopic(),