如何管理 Kafka 连接架构错误？

Question

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

如何防止这种情况发生？

我还想管理错误，例如跟踪它！

Answer 1

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

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