- public EndlessConsumer endlessConsumer(
- KafkaConsumer<String, String> kafkaConsumer,
+ public Consumer<ConsumerRecord<String, Long>> consumer()
+ {
+ return (record) ->
+ {
+ // Handle record
+ };
+ }
+
+ @Bean
+ public EndlessConsumer<String, Long> endlessConsumer(
+ KafkaConsumer<String, Long> kafkaConsumer,
+ ExecutorService executor,
+ Consumer<ConsumerRecord<String, Long>> handler,