使用 slf4j 和 kafka 进行日志记录

Question

我有一个 kafka 应用程序，它从一个主题消费并写入另一个主题。使用slf4j 完成日志记录。它将信息和错误记录到单独的文件中。我的应用有问题，有时会遇到INVALID_FETCH_SESSION_EPOCH 错误。

问题是这个错误最终出现在我的信息文件中，并且应用程序永远挂起并且需要重新启动。一种解决方案是找到这个与我现在的问题无关的无效时代问题的根源。

我的问题是如何检查我的日志中是否存在此错误并在发生此错误时自动重新启动应用程序。我通过扩展 Logger 和 ILoggerFactory 实现了我自己的自定义记录器，但他们仍然无法检查此错误。看来 Kafka 使用不同的 Logger 来编写它。

我也无法检查日志文件，因为它们是由滚动策略创建的，实施起来会很麻烦。 无论如何，在编写之前，我的信息文件中是否有任何内容需要通过我的自定义方法进行检查？

Answer 1

我在我的日志中添加了一个自定义过滤器。在这个过滤器中，我检查消息，只要它包含INVALID_FETCH_SESSION_EPOCH，我就会调用一个方法来重新启动我的应用程序。