@VisibleForTesting long getProducerId() {
    return producerId;
  }
Write the Kafka Consumer PID and Epoch to checkpoint file {@link TransactionalKafkaWriter#openTxFileName}.
kafka-handler/src/java/org/apache/hadoop/hive/kafka/TransactionalKafkaWriter.java