@Override public InputSplit[] getSplits(JobConf jobConf, int i) throws IOException {
    List<KafkaInputSplit> inputSplits;
    try {
      inputSplits = computeSplits(jobConf);
    } catch (InterruptedException e) {
      Thread.currentThread().interrupt();
      throw new IOException(e);
    }
    InputSplit[] inputSplitsArray = new InputSplit[inputSplits.size()];
    return inputSplits.toArray(inputSplitsArray);
  }
Kafka puller input format to read records from a Kafka Queue.
The input split will contain the set of topic partition and start/end offsets.
Records will be returned as bytes array.
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaInputFormat.java