apache-kafka - Confluent Cloud 上没有模式验证
问题描述
我正在使用融合云,目前我想防止在我的 kafka 主题中摄取具有错误模式的消息。为此,我正在使用融合的模式管理功能,我想验证消息是否与指定的模式不匹配,它应该被拒绝。我可以在本地融合,但在云上看不到拒绝。
- 云当前是否支持模式验证?
- 如果没有,我们是否必须通过 kafka 流实现它来自己验证模式?
- 以上答案是否参考了他们的官方文档?或者任何指导此场景用于融合云(非本地)的文档将不胜感激。
提前致谢
解决方案
这在他们的文档中没有正确描述。联系支持后收到电子邮件描述:
目前,我们不支持 Confluent Cloud 中的代理端模式验证,但好消息是它在未来支持的路线图中。我目前没有要发布的 ETA 来分享。
我还看到 Robert Yokota(一位也在 Confluent 的 Schema Registry 团队工作的工程师)在您提供的 github 问题中也证实了这一点。
希望这可以帮助。我们将很快着手结案。
谢谢,
上面提到的 Github 问题可以在这里看到
推荐阅读
- splunk - 使用 regEx ("message":"TransactionRefNo =====> 37010072") 从使用查询的 splunk 事件中提取此特定模式?
- python-3.x - %s 函数 Python 3
- javascript - 如何在 JS 类中定义私有方法
- java - 错误“java.lang.ClassNotFoundException”阻止我运行应用程序
- https - 我们由 Route53 管理的 www.ourdomain.com 未解析为 https
- python - 手势检测应该使用什么网络
- php - SQL 查询结果的 PHP IF 条件
- azure - 连接到在 azure 上运行的 jenkins 容器
- redis - 为什么 redis pubsub 工作独立于数据库?
- html - 为什么这个“res.redirect()”不重定向?