@Override public RecordWriter<NullWritable, KafkaWritable> getRecordWriter(FileSystem fileSystem,
      JobConf jobConf,
      String s,
      Progressable progressable) {
    throw new RuntimeException("this is not suppose to be here");
  }
Kafka Hive Output Format class used to write Hive Rows to a Kafka Queue.
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaOutputFormat.java