import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
- Consumer<String, Message> kafkaConsumer,
- ExecutorService executor,
+ TaskExecutor taskExecutor,
+ Consumer<String, String> kafkaConsumer,
KafkaProperties kafkaProperties,
ApplicationProperties applicationProperties)
{
return
new SimpleConsumer(
KafkaProperties kafkaProperties,
ApplicationProperties applicationProperties)
{
return
new SimpleConsumer(
kafkaProperties.getClientId(),
applicationProperties.getTopic(),
kafkaConsumer);
}
kafkaProperties.getClientId(),
applicationProperties.getTopic(),
kafkaConsumer);
}