Как сопоставить входящие сообщения с группой потребителей в Azure Eventhub - PullRequest
0 голосов
/ 24 апреля 2020

Я пытаюсь использовать Azure EventHub для обработки сообщений, и он отлично работает, пока у меня один отправитель и один потребитель.

Я просто заставляю своего потребителя слушать определенную c Consumer Grooup и все в порядке

Теперь проблема заключается в том, что когда я отправляю сообщения разных типов, которые я хочу обрабатывать различными группами потребителей, я не вижу, как это можно сделать

Я создаю своего отправителя как это

private static EventHubProducerClient eventHubClient = new EventHubProducerClient(eventHubConnectionString, eventHubName);

Но я не нахожу способа сообщить ему, в какую группу потребителей она должна отправлять, она просто отправляет самому концентратору и этот концентратор имеет несколько групп ресурсов

Как мне решить какая группа потребителей получает это сообщение?

Я часами гуглил, не находя способ "сопоставить" входные сообщения от указанных c отправителей с указанным c выходным списком Consumer Group

1 Ответ

0 голосов
/ 24 апреля 2020

Вы не можете указать, какое сообщение будет отправлено указанной группе потребителей. Сообщения отправляются в разделы, все разделы включены в каждую группу потребителей, вы можете проверить схему в этом do c. Снимок экрана, как показано ниже:

enter image description here

Теперь к вам вопрос: когда я отправляю сообщения разных типов, которые я хочу обработать, с помощью другой группы потребителей I Не понимаю, как это можно сделать.

В качестве обходного пути, когда вы отправляете сообщения, вы можете указать свойство для каждого сообщения. Когда вы читаете эти сообщения из группы потребителей, вы также можете использовать это свойство, чтобы определить, хотите ли вы его обработать или отказаться от него.

Надеюсь, это поможет.

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