apache-kafka - Confluent Cloud 上没有模式验证

Question

我正在使用融合云，目前我想防止在我的 kafka 主题中摄取具有错误模式的消息。为此，我正在使用融合的模式管理功能，我想验证消息是否与指定的模式不匹配，它应该被拒绝。我可以在本地融合，但在云上看不到拒绝。

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

提前致谢

Answer 1

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

目前，我们不支持 Confluent Cloud 中的代理端模式验证，但好消息是它在未来支持的路线图中。我目前没有要发布的 ETA 来分享。

我还看到 Robert Yokota（一位也在 Confluent 的 Schema Registry 团队工作的工程师）在您提供的 github 问题中也证实了这一点。

希望这可以帮助。我们将很快着手结案。

谢谢，

上面提到的 Github 问题可以在这里看到

Answer 2

现在似乎已经支持 Confluent Cloud 上的代理端模式验证。请在此处查看。