Confluent Cloud 上没有架构验证

No Schema Validation on Confluent Cloud

我正在使用 confluent cloud,目前我想防止在我的 kafka 主题中摄取具有错误架构的消息。为此,我正在使用 confluent 的模式管理功能,我想验证消息是否与指定的模式不匹配,它应该被拒绝。我可以在 confluent local 上生成这个,但是在 cloud 上看不到 rejection。

  1. 云目前是否支持架构验证?
  2. 如果没有,我们是否必须通过 kafka 流来实现它来自己验证模式?
  3. 以上答案是否参考了他们的官方文档?或者任何指导融合云(非本地)场景的文档将不胜感激。

提前致谢

这在他们的文档中没有正确描述。联系支持后收到电子邮件描述:

At this time, we don't support broker side schema validation in Confluent Cloud, but the good news is it on the roadmap for furture support. I don't have an ETA for the release to share at this time.

I also see Robert Yokota (an engineer who also works in Confluent's Schema Registry team) confirm the same as well in the github issue you've provided.

Hope this helps. We'll be proceeding with case closure shortly.

Thanks,

Github 上面提到的问题可以看到here

Confluent Cloud 上的 Broker-Side Schema Validation 现在似乎已被支持。请勾选 here.