apache-kafka - 如何冻结主题的新版本 AVRO 模式，以便拒绝不合规的消息？

使用 Java 客户端生产者，可以在发布到主题之前对消息进行微调以符合模式格式。

使用kafka rest代理，如果消息无法使用kafka avro模式版本反序列化，如何拒绝消息？这是为了防止不符合模式的客户端添加垃圾。我看到该版本会自动升级到主题的新模式。如何限制发布到主题的消息？这可能是由于所有错误的生产者客户。

我正在搜索文档，并且我是学习 kafka 的新手。我知道消费者可以通过偏移变得更聪明，但我想清理主题中的垃圾。谢谢。

标签： apache-kafkaavroconfluent-schema-registrykafka-rest

例如，如果不在注册表前放置一些拒绝模式更新请求的反向代理，Apache Kafka 就无法防止这种情况发生。而且您必须拒绝绕过该代理的任何人访问