我有一個(gè)卡夫卡應(yīng)用程序,它從一個(gè)主題消費(fèi)并寫入另一個(gè)主題。日志記錄是通過slf4j. 它將信息和錯(cuò)誤記錄到單獨(dú)的文件中。我的應(yīng)用程序有問題,有時(shí)會(huì)遇到INVALID_FETCH_SESSION_EPOCH錯(cuò)誤。問題是這個(gè)錯(cuò)誤最終出現(xiàn)在我的信息文件中,并且應(yīng)用程序永遠(yuǎn)掛起并需要重新啟動(dòng)。一種解決方案是找到這個(gè)與我現(xiàn)在的問題無關(guān)的無效紀(jì)元問題的根源。我的問題是如何檢查日志中是否有此錯(cuò)誤并在發(fā)生錯(cuò)誤時(shí)自動(dòng)重新啟動(dòng)應(yīng)用程序。我通過擴(kuò)展 Logger 和 ILoggerFactory 實(shí)現(xiàn)了自己的自定義記錄器,但它們?nèi)匀粺o法檢查此錯(cuò)誤??磥鞬afka使用了不同的Logger來編寫它。我也無法檢查日志文件,因?yàn)樗鼈兪怯蓾L動(dòng)策略創(chuàng)建的,并且實(shí)施起來會(huì)很麻煩。無論如何,在寫入之前,我的信息文件中的內(nèi)容是否可以通過我的自定義方法進(jìn)行檢查?
1 回答

慕勒3428872
TA貢獻(xiàn)1848條經(jīng)驗(yàn) 獲得超6個(gè)贊
我在日志中添加了自定義過濾器。在此過濾器中,我檢查消息,每當(dāng)消息包含時(shí),INVALID_FETCH_SESSION_EPOCH
我都會(huì)調(diào)用一個(gè)重新啟動(dòng)應(yīng)用程序的方法。
添加回答
舉報(bào)
0/150
提交
取消