package org.apache.kafka.common.errors;

import org.apache.kafka.common.TopicPartition;

/**
 * This exception indicates a record has failed its internal CRC check, this generally indicates network or disk corruption.
 */
public class CorruptRecordException extends RetriableException {

    private static final long serialVersionUID = 1L;

    private TopicPartition topicPartition;
    private long corruptOffset;

    public CorruptRecordException() {
        super("This message has failed its CRC checksum, exceeds the valid size, has a null key for a compacted topic, or is otherwise corrupt.");
    }

    public CorruptRecordException(String message) {
        super(message);
    }

    public CorruptRecordException(Throwable cause) {
        super(cause);
    }

    public CorruptRecordException(String message, Throwable cause) {
        super(message, cause);
    }

    public CorruptRecordException(String message, Throwable cause, TopicPartition topicPartition, long corruptOffset) {
        super(message, cause);
        this.topicPartition = topicPartition;
        this.corruptOffset = corruptOffset;
    }

    public TopicPartition topicPartition() {
        return topicPartition;
    }

    public long corruptOffset() {
        return corruptOffset;
    }
}