我正在使用confluent cloud,目前我希望防止在我的kafka主题中吸收具有错误模式的消息。为此,我正在使用confluent的模式管理特性,在这里我想验证消息是否与指定的模式不匹配,它应该被拒绝。我可以在融合的地方制作,但在云端看不到拒绝。
云目前支持模式验证吗?
如果不是,我们是否必须通过kafka流来实现它以验证模式本身?
以上答案有没有参考他们的官方文件?或者任何指导合流云(非本地)场景的文档都将不胜感激。
提前谢谢
我正在使用confluent cloud,目前我希望防止在我的kafka主题中吸收具有错误模式的消息。为此,我正在使用confluent的模式管理特性,在这里我想验证消息是否与指定的模式不匹配,它应该被拒绝。我可以在融合的地方制作,但在云端看不到拒绝。
云目前支持模式验证吗?
如果不是,我们是否必须通过kafka流来实现它以验证模式本身?
以上答案有没有参考他们的官方文件?或者任何指导合流云(非本地)场景的文档都将不胜感激。
提前谢谢
1条答案
按热度按时间nzkunb0c1#
这在他们的文档中没有正确描述。联系支持人员后,收到电子邮件描述:
目前,我们不支持confluent cloud中的代理端模式验证,但好消息是,它在未来支持的路线图上。我现在没有发布的预计到达时间。
我还看到robertyokota(一位工程师,他也在confluent的schema registry团队工作)在您提供的github问题中也证实了这一点。
希望这有帮助。我们很快就要结案了。
谢谢,
上面提到的github问题可以在这里看到