KafkaIgniteStreamerSelfTest.java 文件源码

java
阅读 21 收藏 0 点赞 0 评论 0

项目:ignite 作者:
/**
 * Creates default consumer config.
 *
 * @param zooKeeper ZooKeeper address <server:port>.
 * @param grpId Group Id for kafka subscriber.
 * @return Kafka consumer configuration.
 */
private ConsumerConfig createDefaultConsumerConfig(String zooKeeper, String grpId) {
    A.notNull(zooKeeper, "zookeeper");
    A.notNull(grpId, "groupId");

    Properties props = new Properties();

    props.put("zookeeper.connect", zooKeeper);
    props.put("group.id", grpId);
    props.put("zookeeper.session.timeout.ms", "400");
    props.put("zookeeper.sync.time.ms", "200");
    props.put("auto.commit.interval.ms", "1000");
    props.put("auto.offset.reset", "smallest");

    return new ConsumerConfig(props);
}
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号