Python中文网

一个关于 编程问题的解答网站.

有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java Kafka使用者异常处理

如果出现无效数据,我需要发送一条消息,说明以下类型的数据无效


{
    "correlationId": "6F9619FF-8B86-D011-B42D-00CF4FC964FF",
    "apiVersion": "1.0",
    "eventCode": "task_started",
    "event_time": "2020-04-25 16:48:33",    
    "sender": "wrs2_tc5_prod",
    "body": {
        "trigger_correlationId": "6F9619FF-8B86-D011-B42D-00CF4FC964FF",
        "store_sap": "2006"
    }
}

有一个SeekToCurrentErrorHandler类接受DeadLetterPublishingRecoverer,但如果出现错误,我需要确定错误的类型,包括三种类型(INVALID ATTRIBUTE, UNDEFINED ERROR, INVALID FORMAT),并向特定主题发送消息

我如何实现这个逻辑


共 (1) 个答案