Отсутствие проверки схемы в Confluent Cloud
Я использую конфлюэнтное облако и в настоящее время хочу, чтобы сообщения с плохой схемой не попадали в мою тему kafka. Для этого я использую функцию управления схемой confluent, где я хочу проверить, не соответствует ли сообщение указанной схеме, оно должно быть отклонено. Я могу произвести это на сливающихся локальных объектах, но в облаке не видно отклонения.
- Поддерживает ли облако в настоящее время проверку схемы?
- Если нет, должны ли мы реализовать его через потоки kafka, чтобы проверить схему самостоятельно?
- Любая ссылка на их официальную документацию для вышеуказанных ответов? Любой документ, описывающий этот сценарий для сливного облака (не локального), был бы оценен.
заранее спасибо
2 ответа
Это не описано должным образом в их документации. После обращения в службу поддержки пришло письмо с описанием:
В настоящее время мы не поддерживаем проверку схемы на стороне брокера в Confluent Cloud, но хорошая новость заключается в том, что она включена в дорожную карту для поддержки будущего. В настоящее время у меня нет расчетного времени прибытия для публикации.
Я также вижу, как Роберт Йокота (инженер, который также работает в команде реестра схем Confluent) подтверждает то же самое в предоставленной вами проблеме github.
Надеюсь это поможет. Вскоре мы приступим к закрытию дела.
Благодарность,
Вышеупомянутую проблему Github можно увидеть здесь
Проверка схемы на стороне брокера в Confluent Cloud, похоже, теперь поддерживается. Пожалуйста, проверьте здесь .