KafkaInputFormat.java 文件源码

@VisibleForTesting
SimpleConsumer getConsumer(final Broker broker) {
    return new SimpleConsumer(broker.getHost(), broker.getPort(), DEFAULT_SOCKET_TIMEOUT_MS,
            DEFAULT_BUFFER_SIZE_BYTES);
}