Не в состоянии правильно понять, как работает группа потребителей Event Hub

Question

Требование Я хочу обрабатывать данные события (одинаковые данные) от нескольких потребителей параллельно

Что я понимаю из документации для обработки одного и того же концентратора событий формы данных, нам необходимо создать несколько групп потребителей.

Группы потребителей позволяют нескольким приложениям-потребителям иметь отдельное представление о потоке событий и независимо читать его в своем темпе и со своими смещениями.

Сохранение сообщения 1, Количество разделов 3

Проблема: я не получаю данные из группы потребителей log1 , вместо log1 Когда я пробовал $ Default и группу потребителей log2, я получал данные параллельно.

Может кто-нибудь помочь мне понять эту проблему?

Answer 1

Исходя из официального документа , ваше понимание верно. Я попытался создать свой центр событий так же, как ваш, чтобы воспроизвести вашу проблему.

И я запускаю 2 EPH через код Java, чтобы контролировать Log1 и log2 отдельно.

Затем я отправляю 10 сообщений в концентратор событий для наблюдения за журналом консоли 2 EPH.

Похоже, я могу получать сообщения от них обоих, однако порядок в них запутан. Я думаю, что ваша проблема delay.

---

Обновление ответа:

Насколько мне известно, delay в концентраторе событий Azure может зависеть от многих аспектов. Может быть сеть, внутренние внутренние механизмы. Однако концентратор событий Azure гарантирует, что ваши данные не будут потеряны в течение эффективного времени хранения.

Если вам необходимо обеспечить получение данных в реальном времени, вы можете использовать Kafka , который используется для построения конвейеров данных в реальном времени и потоковых приложений.