如何管理 Kafka 连接架构错误？
How can I manage Kafka connect schema errors?
我正在使用 kafka connect（融合分发）将 mqtt 代理连接到 kafka 主题 (https://docs.lenses.io/connectors/source/mqtt.html)，但是当消息到达并且不符合预期的模式时，连接器停止！
如何防止这种情况发生？
我也想管理错误，例如跟踪它！
如果您使用的是现成的连接器，则需要满足正确的模式。如果发生任何错误，它将停止连接器。因此，最好的方法是根据错误消息识别模式错误。
如果无法使用现有的连接器，请为您自己创建一个可以满足您需要的连接器。
我正在使用 kafka connect（融合分发）将 mqtt 代理连接到 kafka 主题 (https://docs.lenses.io/connectors/source/mqtt.html)，但是当消息到达并且不符合预期的模式时，连接器停止！
如何防止这种情况发生？
我也想管理错误，例如跟踪它！
如果您使用的是现成的连接器，则需要满足正确的模式。如果发生任何错误，它将停止连接器。因此，最好的方法是根据错误消息识别模式错误。
如果无法使用现有的连接器，请为您自己创建一个可以满足您需要的连接器。