KtGroup.java 文件源码

private static ConsumerConfig createConsumerConfig(String zookeeper, String groupId, String offset) {
    // http://kafka.apache.org/08/configuration.html
    Properties props = new Properties();
    props.put("zookeeper.connect", zookeeper);
    props.put("zookeeper.session.timeout.ms", "400");
    props.put("zookeeper.sync.time.ms", "200");
    props.put("group.id", groupId);

    // Turn off managing the offset in zookeeper and always start at the tail
    // if we enable this in the future make sure to set 'auto.commit.interval.ms'
    props.put("auto.commit.enable", "true");
    props.put("auto.commit.interval.ms", "1000");
    props.put("auto.offset.reset", offset);

    return new ConsumerConfig(props);
}