KafkaRecordReader.java 文件源码

@VisibleForTesting
SimpleConsumer getConsumer(final KafkaInputSplit split, final Configuration conf) {
    return new SimpleConsumer(split.getPartition().getBroker().getHost(), split.getPartition().getBroker()
            .getPort(), getKafkaSocketTimeoutMs(conf), getKafkaBufferSizeBytes(conf));
}