public class ApplicationConfiguration
{
@Bean
- public SumUpRecordHandler sumUpRecordHandler(
+ public ApplicationRecordHandler recordHandler(
KafkaProducer<String, String> kafkaProducer,
ApplicationProperties properties)
{
- return new SumUpRecordHandler(
+ return new ApplicationRecordHandler(
kafkaProducer,
properties.getClientId(),
properties.getTopicOut());
public EndlessConsumer<String, Integer> endlessConsumer(
KafkaConsumer<String, Integer> kafkaConsumer,
ExecutorService executor,
- SumUpRecordHandler sumUpRecordHandler,
+ ApplicationRecordHandler recordHandler,
ApplicationProperties properties)
{
return
properties.getClientId(),
properties.getTopicIn(),
kafkaConsumer,
- sumUpRecordHandler);
+ recordHandler);
}
@Bean