超人学院Hadoop,Hadoop,吴超,Hadoop网络培训,hadoop网络学院,最好hadoop培训机构,Hadoop远程培训,Hadoop免费视频下载,Hadoop学院,吴超Hadoop视频,大数据,云计算

查看: 211|回复: 0

Spark 的 KafkaUtils 报错

[复制链接]

5

主题

8

帖子

53

积分

就业班第12期

积分
53
发表于 2016-11-1 22:24:16 | 显示全部楼层 |阅读模式
老师你好,我使用KafkaUtils.createDirectStream() 方法来消费Kafka的数据, 结果报错:

  java.io.EOFException: received -1 when reading from channel, socket has likely been closed


我又使用 KafkaUtils.createStream() ,没有报错,但是消费不了数据
我又启动了一个kafka控制台消费者,就能够消费到数据

主题,zookeeper,brokerlist都检查过了,请问怎么解决啊?
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

站长推荐 上一条 /4 下一条

QQ|Archiver|手机版|小黑屋|超人学院  

Copyright 2013 最新最精彩-社区论坛 版权所有 All Rights Reserved.

Powered by Discuz! X3.1 Copyright © 2001-2013 Comsenz Inc.    All Rights Reserved.

快速回复 返回顶部 返回列表