使用kafkachannel 启动flume报错

ゝ一世哀愁。 2022-03-18 15:49 320阅读 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 条评论，320人围观）

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

相关阅读

相关 Redis启动报错

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

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

相关 tomcat启动报错

声明：本博文用于学习总结及工作心得问题来的十分突然，在前几分钟项目在本地都还运行的好好的，重启tomcat 后，就抽风了，报错如下: 严重:

古城微笑少年丶/ 2022年07月15日 08:59/ 0 赞/ 368 阅读

相关 NodeManager启动报错

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

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

相关 MYSQL 启动报错

我先说一下我安装mysql的操作吧： 1、开始的时候，安装mysql，是那种解压缩就能用的软件包。我把它解压后，拷贝到/usr/local/ 目录下，并把名字命名为mysql

╰半夏微凉°/ 2022年05月30日 06:55/ 0 赞/ 367 阅读

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

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

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

相关使用kafkachannel 启动flume报错

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NodWJp

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

相关 tomcat 启动报错

1.报错信息为"Unable to complete the scan for annotations for web application \[/portal\] due

我就是我/ 2021年11月17日 23:30/ 0 赞/ 606 阅读

相关 LogStash 启动报错

报错信息如下： {:exception=>LogStash::ConfigLoadingError, :message=>"The following config

今天药忘吃喽~/ 2021年09月28日 01:06/ 0 赞/ 693 阅读

相关 myeclipse启动报错

关键字：弹出对话框：An error has occurred.See the log file…/.log（让你看日志） `org.osgi.framework.

港控/mmm°/ 2021年09月27日 06:12/ 0 赞/ 492 阅读

相关 Nginx启动报错

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

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