Как я могу управлять ошибками схемы соединения Kafka?

Question

Я использую kafka connect (конфлюентное распределение) для подключения брокера mqtt к теме kafka (https://docs.lenses.io/connectors/source/mqtt.html),, но когда приходит сообщение, которое не соответствует ожидаемой схеме, коннектор останавливается!

Как я могу предотвратить это?

Я также хотел бы управлять ошибкой и, например, отслеживать ее!

Answer 1

Если вы используете готовый соединитель, вам необходимо соответствовать правильной схеме.Если произойдет какая-либо ошибка, он остановит разъем.Поэтому лучше всего определить ошибку схемы на основе сообщения об ошибке.

Если использовать существующий соединитель невозможно, создайте его для своего собственного, который может удовлетворить ваши потребности.