TestKafka.java 文件源码

public ConsumerConnector createClient(Properties consumerProperties) {
    consumerProperties.put("metadata.broker.list", getBrokerList());
    consumerProperties.put("group.id", "simple-consumer-" + new Random().nextInt());
    consumerProperties.put("auto.commit.enable","false");
    consumerProperties.put("auto.offset.reset","smallest");
    consumerProperties.put("zookeeper.connect", getZookeeperConnection());
    final kafka.consumer.ConsumerConfig consumerConfig = new kafka.consumer.ConsumerConfig(consumerProperties);
    return Consumer.createJavaConsumerConnector(consumerConfig);
}