Interface DeadLetterPublishingRecoverer.ExceptionHeadersCreator
-
- Enclosing class:
- DeadLetterPublishingRecoverer
public static interface DeadLetterPublishingRecoverer.ExceptionHeadersCreatorUse this to provide a custom implementation to take complete control over exception header creation for the output record.- Since:
- 2.8.4
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidcreate(org.apache.kafka.common.header.Headers kafkaHeaders, java.lang.Exception exception, boolean isKey, DeadLetterPublishingRecoverer.HeaderNames headerNames)Create exception headers.
-
-
-
Method Detail
-
create
void create(org.apache.kafka.common.header.Headers kafkaHeaders, java.lang.Exception exception, boolean isKey, DeadLetterPublishingRecoverer.HeaderNames headerNames)Create exception headers.- Parameters:
kafkaHeaders- theHeadersto add the header(s) to.exception- The exception.isKey- whether the exception is for a key or value.headerNames- the heaader names to use.
-
-