{
@Bean
public SimpleConsumer endlessConsumer(
- Consumer<String, Message> kafkaConsumer,
+ Consumer<String, String> kafkaConsumer,
ExecutorService executor,
KafkaProperties kafkaProperties,
ApplicationProperties applicationProperties)
}
@Bean(destroyMethod = "close")
- public Consumer<String, Message> kafkaConsumer(ConsumerFactory<String, Message> factory)
+ public Consumer<String, String> kafkaConsumer(ConsumerFactory<String, String> factory)
{
return factory.createConsumer();
}