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

Question

假设我有一个名为 account 的 Kafka 主题，其中包含多种消息类型（每种消息类型都有不同的 Avro 模式），例如 account.created、account.deleted 等。 我想了解使用 Spring Cloud Stream 在同一主题上 publish/receive 不同类型是否可行（并且有意义）。特别是，拥有多个 @StreamListener 将非常有用，每个专用于特定类型。根据 this blog post 的说法，这在需要对消息进行排序时非常有用，因为它们与同一实体相关。这种情况下的配置示例是什么？

Answer 1

我想您是在谈论 content-based 路由，它允许在有多个消息的情况下将消息传送到特定的 StreamListener。 您可以使用 condition 属性来做到这一点。请参阅 this section 了解更多详情，如果您仍然不清楚或不明白您要查找的内容，请告诉我们。