我使用kafka connect（合流分发）将mqtt代理连接到kafka主题(https://docs.lenses.io/connectors/source/mqtt.html)，但是当消息到达并且它不符合预期的模式时，连接器停止！我怎样才能防止这种情况发生？我也想管理的错误，例如保持跟踪！
l5tcr1uw1#
如果您使用的是现成的连接器，则需要满足适当的模式。如果发生任何错误，它将停止连接器。因此，最好的方法是根据错误消息来识别模式错误。如果无法使用现有的连接器，请为您自己创建一个可以满足您需要的连接器。
1条答案
按热度按时间l5tcr1uw1#
如果您使用的是现成的连接器，则需要满足适当的模式。如果发生任何错误，它将停止连接器。因此，最好的方法是根据错误消息来识别模式错误。
如果无法使用现有的连接器，请为您自己创建一个可以满足您需要的连接器。