我有一個卡夫卡應用程序，它從一個主題消費并寫入另一個主題。日志記錄是通過slf4j. 它將信息和錯誤記錄到單獨的文件中。我的應用程序有問題，有時會遇到INVALID_FETCH_SESSION_EPOCH錯誤。問題是這個錯誤最終出現在我的信息文件中，并且應用程序永遠掛起并需要重新啟動。一種解決方案是找到這個與我現在的問題無關的無效紀元問題的根源。我的問題是如何檢查日志中是否有此錯誤并在發生錯誤時自動重新啟動應用程序。我通過擴展 Logger 和 ILoggerFactory 實現了自己的自定義記錄器，但它們仍然無法檢查此錯誤?？磥鞬afka使用了不同的Logger來編寫它。我也無法檢查日志文件，因為它們是由滾動策略創建的，并且實施起來會很麻煩。無論如何，在寫入之前，我的信息文件中的內容是否可以通過我的自定義方法進行檢查？
1 回答
慕勒3428872
TA貢獻1848條經驗 獲得超6個贊
我在日志中添加了自定義過濾器。在此過濾器中，我檢查消息，每當消息包含時，INVALID_FETCH_SESSION_EPOCH我都會調用一個重新啟動應用程序的方法。
添加回答
舉報
0/150
提交
取消