如何管理 Kafka 连接模式错误?

Question

我正在使用 kafka connect(融合分发(将 mqtt 代理连接到 kafka 主题 (https://docs.lenses.io/connectors/source/mqtt.html(，但是当消息到达并且它不符合预期的模式时，连接器会停止！

如何防止这种情况发生？

我还想管理错误并跟踪它！

Answer 1

如果您使用的是现成的连接器，则需要满足正确的架构。如果发生任何错误，它将停止连接器。因此，最好的方法是根据错误消息识别架构错误。

如果无法使用现有连接器，请为自己创建一个可以满足您的需求的连接器。