13得票6回答
在运行fatjar时无法加载log4j2

我正在开发一个项目,使用log4j2进行日志记录。在Intellij中进行开发时,一切都很正常,日志记录也按预期完成。log4j2.xml通过Java属性链接到Intellij设置中传递给JVM启动。但是,一旦我尝试运行独立的Gradle构建的fat-jar文件,我遇到了以下问题:java -...

12得票1回答
如何配置Flume以侦听Web API的HTTP请求

我已经建立了一个API Web应用程序,发布在IIS服务器上。我试图配置Apache Flume来监听该Web API并将HTTP请求的响应保存在HDFS中,这是我需要监听的POST方法: [HttpPost] public IEnumerable<Data> obt...

11得票2回答
Apache Flume和Apache Flink的区别

我需要从某个来源读取数据流(在我的情况下是UDP流,但这并不重要),转换每个记录并将其写入HDFS。 对于这个目的,使用Flume或Flink有什么区别吗? 我知道可以使用自定义拦截器在Flume中转换每个事件。 但是我在Flink上还是新手,所以对我来说它看起来会做同样的事情。 应该...

8得票1回答
Flume Twitter代理生成的Avro文本文件无法在Java中读取

无法使用Flume twitter代理流式读取和解析文件,无论是使用Java还是Avro工具。 我的要求是将avro格式转换为JSON格式。 使用任何一种方法时,都会出现异常:org.apache.avro.AvroRuntimeException: java.io.IOException:...