THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
package org.apache.kafka.common.errors; import org.apache.kafka.common.KafkaException; import org.apache.kafka.common.TopicPartition; /** * Any exception when encountering an corrupted/invalid record in the consumer */ public class InoperativeRecordException extends KafkaException { private static final long serialVersionUID = 1L; private TopicPartition partition; private long offset; public InoperativeRecordException(TopicPartition partition, long offset, String message, Throwable cause) { super(message, cause); this.partition = partition; this.offset = offset; } public TopicPartition partition() { return partition; } public long offset() { return offset; } } |
...
Code Block |
---|
package org.apache.kafka.common.errors; import org.apache.kafka.common.TopicPartition; /** * Any exception during deserialization in the consumer */ public class RecordDeserializationException extends SerializationException { private static final long serialVersionUID = 1L; private TopicPartition partition; private long offset; public RecordDeserializationException(TopicPartition partition, long offset, String message, Throwable cause) { super(message, cause); this.partition = partition; this.offset = offset; } public TopicPartition partition() { return partition; } public long offset() { return offset; } /* avoid the expensive and useless stack trace for serialization exceptions */ @Override public Throwable fillInStackTrace() { return this; } } |
...