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

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

flume.png

这个怎么破？
2015-11-26 添加评论
分享

奔跑的大象

赞同来自:

为什么不flume导入kafka，spark streaming消费kafka数据呢？
2015-11-26 0 0
分享

ycyzlp

赞同来自:

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

要回复问题请先登录或注册

Copyright © 2021