KafkaDataSpout.java 文件源码

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

项目:storm-demos 作者:
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);
  }
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号