本文共 841 字，大约阅读时间需要 2 分钟。

   在使用kafkachannel时，启动flume报错

    org.apache.flume.conf.ConfigurationException: Broker List must be specified

    原因是我使用的flume的版本是1.6.0的，kafka是kafka_2.11-0.10.2.1，

    kafka使用的是新版，而flume使用的比较老，在定义broker时，flume新老版本不一致

这个是我原来写的配置，这个是flume1.7以后才是这样写，所以会报上面的错

a0.channels.c1.type = org.apache.flume.channel.kafka.KafkaChannel

a0.channels.c1.kafka.bootstrap.servers = bigdata01:9092,bigdata02:9092,bigdata03:9092

a0.channels.c1.kafka.topic = userif

#a0.channels.c1.parseAsFlumeEvent = false

a0.sources.r1.channels = c1

解决就是把--bootstrap-servers 换成brokerList，或者换一个高一点的flume版本，为了确保万无一失，把zookeeper.jar 拷贝到flume的lib下

a0.channels.c1.type = org.apache.flume.channel.kafka.KafkaChannel

a0.channels.c1.brokerList = bigdata01:9092,bigdata02:9092,bigdata03:9092

a0.channels.c1.zookeeperConnect=192.168.136.150:2181

a0.channels.c1.topic = userif

a0.sources.r1.channels = c1

转载地址：http://sykni.baihongyu.com/