使用kafkachannel 启动flume报错

ゝ一世哀愁。 2022-03-18 15:49 331阅读 0赞

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NodWJpbmd6aHVveHVl_size_16_color_FFFFFF_t_70][]

>    在使用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

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NodWJpbmd6aHVveHVl_size_16_color_FFFFFF_t_70]: /images/20220318/145e916d10d444cd8fc4c7a690fe55aa.png

发表评论取消回复

表情：

评论列表（有 0 条评论，331人围观）

还没有评论，来说两句吧...

相关阅读

相关 Redis启动报错

我发现在Redis安装目录下，双击启动 redis-cli.exe ，这时候会报错：Could not connect to Redis at 127.0.0.1:6379:

た入场券/ 2022年12月04日 07:39/ 0 赞/ 255 阅读

相关 NodeManager启动报错

Nodeemanager异常 org.fusesource.leveldbjni.internal.NativeDB$DBException: Corruption: chec

╰+哭是因爲堅強的太久メ/ 2022年06月06日 01:13/ 0 赞/ 396 阅读

相关 zabbix启动报错

我安装了一个zabbix监控，一直很顺利，后来不知道问什么服务起不来了，服务器总是提醒我10051端口没有打开，于是我仔细理了一遍又一遍，服务总是启动不起来： Startin

﹏ヽ暗。殇╰゛Y/ 2022年05月29日 02:19/ 0 赞/ 163 阅读

相关 flume-ng启动时遇到报错时的解决

在命令行下启动bin/flume-ng时,竟然遇到报错,找到如下解决办法错误如下： bin/flume-ng: line 82: syntax error in

爱被打了一巴掌/ 2022年04月21日 15:31/ 0 赞/ 475 阅读

相关使用kafkachannel 启动flume报错

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NodWJp

ゝ一世哀愁。/ 2022年03月18日 15:49/ 0 赞/ 332 阅读

相关 jetty启动报错

报错信息： java.lang.RuntimeException: Error scanning entry com/ibm/icu/impl/data/LocaleEl

蔚落/ 2022年02月28日 05:44/ 0 赞/ 391 阅读

相关启动docker报错

1、启动docker systemctl restart docker.service 报错后用以下命令查看docker状态 root@X555LB:~\

叁歲伎倆/ 2022年02月13日 15:11/ 0 赞/ 443 阅读

相关 Docker启动报错

time="2015-02-10T15:26:08+08:00" level="info" msg="+job serveapi(unix:///var/run/docker.

分手后的思念是犯贱/ 2022年02月05日 00:37/ 0 赞/ 331 阅读

相关启动kafka报错

执行启动kafka服务的命令时报错：nohup bin/kafka-server-start.sh config/server.properties 2>&1 & \[201

川长思鸟来/ 2021年11月17日 05:08/ 0 赞/ 502 阅读

相关 Nginx启动报错

1，nginx: [emerg] getpwnam(“www”) failed inux 64系统中安装nginx时如果出现错误：nginx: [emerg] getp...

你的名字/ 2021年03月30日 16:15/ 0 赞/ 773 阅读