protected abstract int compareToLastMsg(Pair<K,V> tupleKeyValue,Pair<byte[],byte[]> lastReceivedKeyValue);

protected abstract int compareToLastMsg ( Pair < K , V > tupleKeyValue , Pair < byte [ ] , byte [ ] > lastReceivedKeyValue ) ;
compare the incoming tuple with the last received message in kafka .
