@Override
    public int compareTo(KafkaETLKey o) {
        if (_inputIndex != o._inputIndex)
            return _inputIndex = o._inputIndex;
        else {
            if  (_offset > o._offset) return 1;
            else if (_offset < o._offset) return -1;
            else {
                if  (_checksum > o._checksum) return 1;
                else if (_checksum < o._checksum) return -1;
                else return 0;
            }
        }
    }