小编wxm*_*rio的帖子

如何使用 InputStream 读取 orcFile?

OrcFile reader 有两个参数,文件路径和文件系统配置,例如:

Reader reader = OrcFile.createReader(path, OrcFile.readerOptions(config));
Run Code Online (Sandbox Code Playgroud)

但是我想读取一个不在 hadoop 上的 orcFile,只是一个本地文件,所以 orcReader 没有 hdfs 路径。

我该怎么办?

hadoop orc

5
推荐指数
0
解决办法
415
查看次数

如何使用kafka0.10.x获取所有组列表

当我使用kafka0.8.x时,我可以通过路径获取所有带有zookeeper的组列表/consumers/group_id,因为偏移将在0.8.x中提交到zookeeper.

但是在0.10.x的版本中,offset提交给kafka代理,就像一个路径/brokers/topics/__consumer_offsets/consumerszookeeper中的路径一样.所以我无法通过zookeeper获得消费者群体列表.

apache-kafka kafka-consumer-api apache-zookeeper apache-kafka-connect

3
推荐指数
1
解决办法
1万
查看次数