草庐IT

result_apache_log_parser

全部标签

java - 在 log4j2 中按类名过滤

我正在使用log4j2,但我不知道如何按类名进行过滤。我试过使用RegexFilter但它只过滤文本消息。在旧的log4j中,标签'filter'就足够了有人知道现在该怎么做吗?提前致谢!更新:好的,我做到了!我需要定义一个记录器并在属性“名称”中设置类名: 最佳答案 如果您遵循记录器的命名约定,这在Log4j中会自动工作。在您的代码中,使用类名声明记录器:Loggerlogger=LogManager.getLogger(MyClass.class);记录器自动分配名称fully.qualified.class.name.of.M

java - 使用 Log4J 或 LogBack 的控制台上的进度条

我有一个使用Log4J打印其输出的控制台应用程序。这很有用,因为我可以轻松地实现一个开关以选择性地显示调试消息,即使它们在默认情况下是隐藏的。此应用程序有一些长时间运行的操作,进度条将适合这些操作。使用Log4J或LogBack实现此功能的最佳方法是什么? 最佳答案 要向控制台写入进度条或任何类型的更新文本,只需以\r(回车)而不是\n(换行)结束输出)以便下一行将其覆盖。这question进入更多细节。F-ANSI库使您能够轻松生成美观的控制台输出,包括覆盖前一行。但如果您打算使用日志记录框架,这不仅不可能,而且也不是您想要的。正

java - 如何绑定(bind)SLF4J和Log4J?

我正在尝试使用slf4j+log4j设置一个项目,但该死的东西就是不起作用......我不断收到异常:FailedtoinstantiateSLF4JLoggerFactoryReportedexception:java.lang.NoClassDefFoundError:org/apache/log4j/Levelatorg.slf4j.LoggerFactory.bind(LoggerFactory.java:129)atorg.slf4j.LoggerFactory.performInitialization(LoggerFactory.java:108)atorg.slf4j.

java - 使用日期和时间戳为每次运行创建 log4j 日志文件

所有,似乎这个问题已发布多次,但我仍然没有找到适合我的问题的解决方案。我提到了this和this,但它不起作用。根据下面的属性文件,每次都会创建一个包含日期的新文件但是我想创建一个具有以下格式的日志文件并且每次执行我的应用程序时都需要生成,logFileName_MM_DD_YY-HH_MM_SS.log(或)logFileName.log_YYYY_MM_DD_HH_MM_SS#Rootloggeroptionlog4j.rootLogger=INFO,file,stdout#Redirectlogmessagestoconsolelog4j.appender.stdout=org.

java - RabbitMQ - Apache Camel Reading Messages 如何处理失败的消息

我有以下PHP应用程序。将用户注册发布到消息队列。Java应用程序从该队列中读取并导入它。希望下图能够描述它。我只处理Java方面的事情。json消息已经存在于队列中。路由(Java消费端)。@ComponentpublicclassSignUpRouting{errorHandler(deadLetterChannel("rabbitmq://signUpDeadLetter.exchange?username=etc..").useOriginalMessage());from("rabbitmq://phpSignUp.exchange?username=etc....").ro

java - Apache Storm Bolt 任务在一段时间后未收到消息

我们有一个Storm拓扑,其中配置了一个spout和两个bolts。Spout不断地从数据库中查询数据并将元组发送到第一个bolt进行一些处理。第一个bolt进行一些处理并将元组发送到第二个bolt,第二个bolt调用第三方网络服务并发送数据。所以,一段时间后发生了什么,最后一个bolt没有得到任何元组,如果我们重新启动拓扑它工作正常。这里只有最后一个bolt有问题。其他spout和firstbolt运行良好,我没有使用acking框架。在这种情况下,我只配置了一个worker`。TopologyBuilderbuilder=newTopologyBuilder();builder.s

java - Apache Poi 3.13 找不到打开 XLSX 文件的类

我正在使用apachePOI通过Java读写Excel文件,但我无法在源代码中找到WorkbookFactory或XSSFWorkbook来读取xlsx文件。pom.xml:3.13org.apache.poipoi${poi.version}org.apache.poipoi-ooxml${poi.version}我在apachepoi的变更日志中找不到任何可能导致此行为的信息。编辑:这是我的实现(暂时只是一个简单的方法)publicstaticHSSFSheetgetXLSSheet(StringfileName,intsheetIndex)throwsIOException{In

java - kafka log-compaction消费数据

我正在阅读最新版本的kafka中的日志压缩,我很好奇这对消费者有何影响。消费者是否像以前一样工作,或者是否有一个新的流程来获取所有最新值?对于“标准”Kafka主题,我使用消费者组来维护指向最新值的指针。但是,如果Kafka基于键而不是时间来保存值,我想知道消费者群体将如何运作? 最佳答案 它不会影响消费者的工作方式。如果你只对每个键的最新值感兴趣并阅读整个主题,你可能仍然会看到一个键的“重复项”(如果不是所有重复项都被消除,或者在上次压缩运行后写入新消息)因此你只关心关于每个键的最新值。关于消费者组:当主题被压缩时,有效偏移量范围

java - Apache Spark 如何将函数发送到引擎盖下的其他机器

我开始使用Pyspark进行一些数据处理。我可以做一些像这样的事情对我来说很有趣rdd.map(lambdax:(x['somekey'],1)).reduceByKey(lambdax,y:x+y).count()它会将这些函数中的逻辑发送到可能多台机器上以并行执行。现在,如果我有Java背景,如果我想将包含某些方法的对象发送到另一台机器,那台机器需要知道通过网络流式传输的对象的类定义。最近java有了函数式接口(interface)的想法,它将在编译时为我创建该接口(interface)的实现(即MyInterfaceimpl=()->System.out.println("Stu

java - Apache Kafka 1.0.0 Streams API Multiple Multilevel groupby

我如何在KafkaStreamsAPI中使用具有多个约束的.groupby。与下面的Java8StreamsAPI示例相同publicvoidtwoLevelGrouping(Listpersons){finalMap>>personsByCountryAndCity=persons.stream().collect(groupingBy(Person::getCountry,groupingBy(Person::getCity)));System.out.println("PersonslivinginLondon:"+personsByCountryAndCity.get("UK"