Kafka主题停止接收消息

Question

当producer中的模式发生变化时，我需要停止接收来自producer的消息。例如，producer-1向schema-1中的主题发送消息，而producer-2向schema-2中的相同主题发送消息，因此我需要停止从producer-1接收消息。我能设置一些属性吗?在这种情况下我能做什么？

Answer 1

你的用例是什么？您可以在数据中添加版本属性。在消费者端，您可以处理具有特定版本值的消息，并过滤/丢弃其余的消息。