private void checkExceptions() throws IOException {
    if (sendExceptionRef.get() != null) {
      LOG.error("Send Exception Aborting write from writerId [{}]", writerId);
      producer.close(Duration.ofMillis(0));
      throw new IOException(sendExceptionRef.get());
    }
  }
@param topic Kafka Topic.
@param writerId Writer Id use for logging.
@param properties Kafka Producer properties.
kafka-handler/src/java/org/apache/hadoop/hive/kafka/SimpleKafkaWriter.java