mvn 编译bootcamp test_kafka 报错

已邀请:

fish - Hadooper

赞同来自: Poodah

看起来是网络原因导致下载包失败,再重新执行一下试试。

fish - Hadooper

你kafka服务启动了么,在正常服务?

fish - Hadooper

这代码就是样例代码吧?
我确认个问题,你使用的kafka版本是?
At least two parameters:1 topic_name,2:group_name
错误中提示输入两个参数。
实际上,不要输入的。因为你已经写到代码里了。
直接把main方法中判断args.length<2的代码块去掉
确保test_kafka项目中的配置四个配置文件和当前hadoop集群的配置文件内容是一样的。
core-site.xml        hdfs-site.xml        mapred-site.xml      yarn-site.xml
用hadoop jar执行
看看目录存在不,还有目录的权限
hadoop fs -ls /user/

fish - Hadooper

尝试将启动命令由java -cp改成hadoop jar。

fish - Hadooper

请在TestHadoopConsumer应用中自行打印更多的log,尝试寻找问题到底出现在什么地方(是根本没从kafka获取消息?还是从Kafka获取消息之后写到hdfs失败)。 记住,多打log,培养自己理解代码寻找问题的能力。

要回复问题请先登录注册