Несколько типов сообщений на тему Кафки - PullRequest
0 голосов
/ 19 июня 2019

Предположим, у меня есть тема Kafka с именем account с несколькими типами сообщений (каждый со своей схемой Avro), например account.created, account.deleted и так далее.Я хотел бы понять, возможно ли (и имеет ли это смысл) публиковать / получать разные типы по одним и тем же темам с помощью Spring Cloud Stream.В частности, было бы очень полезно иметь несколько @StreamListener, каждый из которых посвящен определенному типу.Согласно этому сообщению в блоге это действительно полезно, когда нужно заказать сообщения, потому что они связаны с одним и тем же объектом.Что является примером конфигурации в этом случае?

1 Ответ

1 голос
/ 19 июня 2019

Я думаю, что вы говорите о контентной маршрутизации, которая позволяет доставлять сообщения на определенный StreamListener для случаев, когда их несколько. Вы делаете это с помощью атрибута condition. Пожалуйста, обратитесь к этому разделу для получения более подробной информации и дайте нам знать, если все еще неясно или нет то, что вы ищете.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...