apache-kafka - 每个 Kafka 主题有多种消息类型

Question

假设我有一个 Kafka 主题，该主题以account多种消息类型命名（每种消息类型都有不同的 Avro 模式），例如account.created等等account.deleted。我想了解使用 Spring Cloud Stream 在相同主题上发布/接收不同类型是否可行（并且有意义）。特别是，有几个 非常有用@StreamListener，每个都专用于特定类型。根据这篇博客文章，这在需要订购消息时非常有用，因为它们与同一实体相关。这种情况下的配置示例是什么？

标签： apache-kafkaspring-kafkaspring-cloud-streamconfluent-schema-registry

Answer 1

我认为您正在谈论基于内容的路由，该路由允许将消息传递到特定StreamListener的情况下有多个。condition您可以通过使用属性来做到这一点。请参阅此部分了解更多详细信息，如果仍不清楚或不是您要查找的内容，请告诉我们。