@Override public boolean equals(Object o) {
    if (this == o) {
      return true;
    }
    if (!(o instanceof KafkaWritable)) {
      return false;
    }
    KafkaWritable writable = (KafkaWritable) o;
    return partition == writable.partition
        && offset == writable.offset
        && timestamp == writable.timestamp
        && Arrays.equals(value, writable.value)
        && Arrays.equals(recordKey, writable.recordKey);
  }
Writable implementation of Kafka ConsumerRecord.
Serialized in the form:
{@code timestamp} long| {@code partition} (int) | {@code offset} (long) | {@code value.size()} (int) |
{@code value} (byte []) | {@code recordKey.size()}| {@code recordKey (byte [])}
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaWritable.java