将日志数据从flume导入到kafka时,同时用sparkstreaming读取数据时报错

将日志数据从flume导入到kafka时,同时用sparkstreaming读取数据时报如下错误

flume.png

这个怎么破?

奔跑的大象

赞同来自:

为什么不flume导入kafka,spark streaming消费kafka数据呢?

ycyzlp

赞同来自:

我在ide中写了spark streaming和kafka集成的代码,执行这个程序后,同时启动了一个生产者终端,在终端中输入简单的几个字母后,ide可以将生产都输入的字母打印出来,我用flume导入kafka其实就是想模拟一下这个生产者,因为我发现如果等flume导入kafka后,再执行这个spark streaming集成kafka的代码,ide是读不出来数据的,是我的代码有问题还是我的思路不对?还请老师指点

要回复问题请先登录注册