@EnableConfigurationProperties({ KafkaProperties.class, ApplicationProperties.class })
public class ApplicationConfiguration
{
+ @Bean
+ public AdderBusinessLogic adder()
+ {
+ return new AdderBusinessLogic();
+ }
+
+ @Bean
+ public MessageHandler messageHandler(
+ KafkaProperties properties,
+ AdderBusinessLogic adder)
+ {
+ return new MessageHandler(
+ properties.getClientId(),
+ adder);
+ }
+
@Bean
public SimpleConsumer simpleConsumer(
Consumer<String, Message> kafkaConsumer,
+ MessageHandler messageHandler,
KafkaProperties kafkaProperties,
ApplicationProperties applicationProperties)
{
new SimpleConsumer(
kafkaProperties.getClientId(),
applicationProperties.getTopic(),
- kafkaConsumer);
+ kafkaConsumer,
+ messageHandler);
}
@Bean