首先确保本地hadoop环境正常(配置windows hadoop开发环境)
运行环境:spark 3.0.2 | hdfs 3.1.1 | kafka 2.0.0

问题描述:
执行idea sss读取kafka报错如下

Exception in thread "main" java.lang.IllegalArgumentException: Pathname /C:/Users/LZX/AppData/Local/Temp/temporary-e832fafa-8da6-4250-bdc7-31b91d9be96e from hdfs://xxx/C:/Users/LZX/AppData/Local/Temp/temporary-e832fafa-8da6-4250-bdc7-31b91d9be96e is not a valid DFS filename.

解决办法:
将resource目录下 hdfs core两个xml改名或暂时移出

在这里插入图片描述

运行结果:
在这里插入图片描述

Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐