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

Question

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

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

我的管道如下所示：

有两种可能性，要么我们预期错误并创建特定结构，要么我们不预期它，因为我们之前不必面对它。

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

• 导致应用程序错误的损坏输入数据 => 格式化异常
• 系统故障转移（数据库、服务……）=> 未知异常

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

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

在此先感谢您的帮助 ！

标签： javaerror-handlingapache-kafka