DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
Key | Key of the input message that triggered the sub-topology, null if triggered by punctuate |
Value | If available, contains the value of the input message that triggered the sub-topology, null if triggered by punctuate |
Headers | Existing context headers are automatically forwarded into the new DLQ record |
Header: __streams.errors.exception | Name of the thrown exception |
Header: __streams.errors.stacktrace | Stacktrace of the thrown exception |
Header: __streams.errors.message | Thrown exception message |
Header: __streams.errors.topic | Source input topic, null if triggered by punctuate |
Header: __streams.errors.partition | Source input partition, null if triggered by punctuate |
Header: __streams.errors.offset | Source input offset, null if triggered by punctuate |
...
| Code Block | ||
|---|---|---|
| ||
public interface ProductionExceptionHandler extends Configurable {
...
enum ProductionExceptionHandlerResponse {
. . .
public Iterable<org.apache.kafka.clients.producer.ProducerRecord<byte[], byte[]> deadLetterQueueRecords() {
return this.deadLetterQueueRecord;
}
public ProductionExceptionHandlerResponse andAddToDeadLetterQueue(Iterable<org.apache.kafka.clients.producer.ProducerRecord<byte[], byte[]>> deadLetterQueueRecords) {
this.deadLetterQueueRecord = deadLetterQueueRecord;
return this;
}
}
}
|
...