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