private static ConsumerConfig createConsumerConfig(String zookeeper, String groupId) {
/**
* this method used to set kafka-consumer configuration
*
* Args :
* m_zookeeper: zookeeper address with port
* m_groupId : kafka-consumer consumer group
*
* Return :
* an object of ConnsumerConfig
*
*/
Properties props = new Properties();
props.put("zookeeper.connect", zookeeper);
props.put("group.id", groupId);
props.put("zookeeper.session.timeout.ms", "400");
props.put("zookeeper.sync.time.ms", "200");
props.put("auto.commit.interval.ms", "1000");
return new ConsumerConfig(props);
}
KafkaDataSpout.java 文件源码
java
阅读 19
收藏 0
点赞 0
评论 0
项目:storm-demos
作者:
评论列表
文章目录