...
It introduces a new non-retriable exception InvalidKeyException InvalidRecordKeyException. Going forward user request will fail without doing retries, if they try to produce to a log compacted topic with a null key.
...
Add a new error code and exception as follows :
Error Code :
INVALID_RECORD_KEY(45, new InvalidKeyException InvalidRecordKeyException("Message key is invalid."))
...
| Code Block | ||
|---|---|---|
| ||
public class InvalidKeyExceptionInvalidRecordKeyException extends ApiException { private static final long serialVersionUID = 1L; public InvalidKeyExceptionInvalidRecordKeyException() { super(); } public InvalidKeyExceptionInvalidRecordKeyException(String message, Throwable cause) { super(message, cause); } public InvalidKeyExceptionInvalidRecordKeyException(String message) { super(message); } public InvalidKeyExceptionInvalidRecordKeyException(Throwable cause) { super(cause); } } |
...