Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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
languagejava
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);
    }
}

...