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