search

spring-cloud / spring-cloud-stream-binder-kafka

Spring Cloud Stream binders for Apache Kafka and Kafka Streams
Apache License 2.0
331 stars 301 forks source link

Custom DLQ Destination Resolver #976

Closed sobychacko closed 4 years ago

sobychacko commented 4 years ago

Allow applications to provide a custom DLQ destination resolver implementaiton by providing a new interface DlqDestinationResolver as part of binder's public contract. This interface is a BiFunction extension using which the applications can provide more fine grained control over where to route records in error.

Adding test to verify.

Adding docs.

Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/966