DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
| 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;
}
}
}
|
DeserializationExceptionHandler.java
...
- Adding the public ProducerRecord<byte[], byte[]> deadLetterQueueRecord; attribute in the ProcessingHandlerResponse DeserializationHandlerResponse
| Code Block | ||
|---|---|---|
| ||
public interface DeserializationExceptionHandler extends Configurable {
...
/**
* Enumeration that describes the response from the exception handler.
*/
enum DeserializationHandlerResponse {
. . .
public DeserializationHandlerResponse andAddToDeadLetterQueue( public Iterable<org.apache.kafka.clients.producer.ProducerRecord<byte[], byte[]>>> deadLetterQueueRecords() {;
public this.deadLetterQueueRecord = deadLetterQueueRecord;
return this;
}DeserializationHandlerResponse andAddToDeadLetterQueue(Iterable<org.apache.kafka.clients.producer.ProducerRecord<byte[], byte[]>> deadLetterQueueRecords);
}
}
|
ProcessingExceptionHandler.java
...
- Adding the public ProducerRecord<byte[], byte[]> deadLetterQueueRecord; attribute in the ProductionExceptionHandlerResponse ProcessingExceptionHandlerResponse
| Code Block | ||
|---|---|---|
| ||
public interface DeserializationExceptionHandler extends Configurable {
...
/**
* Enumeration that describes the response from the exception handler.
*/
enum DeserializationHandlerResponseProcessingHandlerResponse {
. . .
public DeserializationHandlerResponse andAddToDeadLetterQueue( public Iterable<org.apache.kafka.clients.producer.ProducerRecord<byte[], byte[]>>> deadLetterQueueRecords() {;
public this.deadLetterQueueRecord = deadLetterQueueRecord;
return this;
}ProcessingHandlerResponse andAddToDeadLetterQueue(Iterable<org.apache.kafka.clients.producer.ProducerRecord<byte[], byte[]>> deadLetterQueueRecords);
}
}
|
ErrorHandlerContext.java
...