OrcFile reader 有两个参数,文件路径和文件系统配置,例如:
Reader reader = OrcFile.createReader(path, OrcFile.readerOptions(config));
Run Code Online (Sandbox Code Playgroud)
但是我想读取一个不在 hadoop 上的 orcFile,只是一个本地文件,所以 orcReader 没有 hdfs 路径。
我该怎么办?
当我使用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