- public EndlessConsumer<String, Long> endlessConsumer(
- org.apache.kafka.clients.consumer.Consumer<String, Long> kafkaConsumer,
- ExecutorService executor,
- Consumer<ConsumerRecord<String, Long>> handler,
- KafkaProperties kafkaProperties,
- ApplicationProperties applicationProperties)
+ public DeadLetterPublishingRecoverer recoverer(
+ ApplicationProperties properties,
+ KafkaOperations<?, ?> template)