springboot+kafka应用程序中的java错误管理

Question

我正在尝试在我的应用程序中创建一个错误管理系统

我从IBM AS400收到数据，我们开发了一个从AS400到卡夫卡的连接器

我的管道是这样的：

有两种可能性，要么我们预料到错误并创建了一个特定的结构，要么我们没有预料到它，因为我们以前不必面对它

我列出了以下可能的错误：

• 输入数据损坏，导致应用程序错误=>；格式化异常
• 系统故障切换（数据库、服务等）=>；未知异常

问题是，我必须如何在事后管理这些错误？在没有任何人工/手动重放机制的情况下，我必须考虑哪些因素来管理错误

如果错误发生在格式化异常的情况下，我如何继续处理

提前感谢您的帮助