apache-kafka - 如何在 kafka 中强制执行模式验证

Question

我正在使用 Kafka & Schema-registry。定义了一个模式，在生产者端使用 confluent 的 KafkaAvroSerializer。一切正常。

另一方面，如果生产者在不遵守模式的情况下发布事件，则发布没有任何问题。

了解到 Kafka 只是序列化的二进制文件，不会检查数据和功能是否按设计工作。

想知道是否有更好的方法来强制执行更强的模式验证，以便主题不会被不良数据污染？

Answer 1

创建主题时使用以下“--config”标签。它们分别对值和键执行消息模式验证。这两个规则是相互独立的；您可以启用其中一个或两个。不合规的消息将导致客户端收到来自 kafka 代理的错误。
https://www.confluent.io/blog/data-governance-with-schema-validation/

confluent.value.schema.validation=true 
confluent.key.schema.validation=true