DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
public static final String PRODUCER_EXCEPTION_HANDLER_CLASS_CONFIG = "producer.exception.handler";
private static final String PRODUCER_EXCEPTION_HANDLER_CLASS_DOC = "Exception handling class that implements the <code>org.apache.kafka.common.errors.ProducerExceptionHandler</code> interface.";.
.
.
static {
CONFIG = new ConfigDef().define(
.....
.
.
.
.define(PRODUCER_EXCEPTION_HANDLER_CLASS_CONFIG,
Type.CLASS,
null,
Importance.MEDIUM,
PRODUCER_EXCEPTION_HANDLER_CLASS_DOC);
} |
Compatibility, Deprecation, and Migration Plan
To configure own handler, the user must implement the above introduced interface and add the class name in producer configuration with the key: producer.exception.handler.
...