我正在尝试建立一个管道，我只是意识到我不知道为什么会有错误，为什么会有错误主题。有一些元数据，我将指望成为某些值，但除此之外，有什么是一个“典型的”Kafka错误？我不知道“典型的”Kafka错误主题是用来做什么的。这是专门针对streams应用程序的。谢谢你的帮助。
ruyhziif1#
流式处理环境中的一个错误主题示例是，它包含未能遵守其约定的消息。。示例：如果传入事件的格式是特定的json格式，那么spark应用程序将首先尝试将事件解析为符合events json契约的类。如果格式正确，将对其进行解析，然后应用程序继续。如果格式不正确，解析将失败，json字符串将发送到错误主题。其他用例可以是将事件发送回错误主题，以便稍后处理。。ie网络问题连接到其他服务。
1条答案
按热度按时间ruyhziif1#
流式处理环境中的一个错误主题示例是，它包含未能遵守其约定的消息。。示例：如果传入事件的格式是特定的json格式，那么spark应用程序将首先尝试将事件解析为符合events json契约的类。
如果格式正确，将对其进行解析，然后应用程序继续。
如果格式不正确，解析将失败，json字符串将发送到错误主题。
其他用例可以是将事件发送回错误主题，以便稍后处理。。ie网络问题连接到其他服务。