【发布时间】：2018-07-22 20:34:53
【问题描述】：
当生产者中的架构发生变化时，我需要停止接收来自生产者的消息。例如，producer-1 向 schema-1 中的主题发送消息，之后 producer-2 向 schema-2 中的同一主题发送消息，因此我需要停止接收来自 producer-1 的消息。我可以设置一些属性或者在这种情况下我可以做什么？
【问题讨论】：
-
你可以考虑使用 Confluent Schema Registry：docs.confluent.io/current/schema-registry/docs/index.html 这个工具的目的正是你所说的（+不同的兼容模式）。
-
我也考虑兼容模式，所以现在我可以为一个主题编写不同的模式。但是当我在第二个模式中编写消息时，我需要停止从第一个模式接收消息。也许您可以指定我需要在本文档中阅读的内容？
标签： apache-kafka kafka-producer-api