title: Error handling in Spring Cloud Stream Kafka in Batch mode
body: <p>I am using Spring Cloud Stream and Kafka Binder to consume messages in batches from a Kafka Topic. I am trying to implement an error handling mechanism. As per my understanding I can't use Spring Cloud Stream's <code>enableDLQ</code> property in batch mode.</p>
  <p>I have found <code>RecoveringBatchErrorHandler</code> and <code>DeadLetterPublishingRecoverer</code> to retry and send failure messages from the spring-kafka documentation. But I am not able to understand how to send the records to a custom DLQ topic following the functional programming standards. All the examples I can see is using KafkaTemplates.</p>
  <p>Are there any good example where I can find the implementation?</p>
  <p>This is the spring doc I have been referring to.</p>
  <p><a href="https://docs.spring.io/spring-kafka/docs/2.5.12.RELEASE/reference/html/#recovering-batch-eh" rel="nofollow noreferrer">https://docs.spring.io/spring-kafka/docs/2.5.12.RELEASE/reference/html/#recovering-batch-eh</a></p>