Skip to main content

Event Hub — cerebro-ingest-eh

Azure Event Hub is the streaming data bus for the ingest pipeline. It decouples the Ingest Service (producer) from the Router Service (consumer).

Details

FieldValue
Namespacecerebro-ingest-eh
Resource grouptesting
RegionSouth India
SKUStandard

Data Flow

Ingest Service → Event Hub (cerebro-ingest-eh) → Router Service
(producer) (consumer)

┌────────────┼──────────────┐
▼ ▼ ▼
Review Svc Config Svc Assistant Agent

Viewing in Azure Portal

  1. portal.azure.com → Resource groups → testing → cerebro-ingest-eh
  2. Click Event Hubs to see the individual hub topics
  3. Click Shared access policies to manage connection strings

Get Connection String

az eventhubs namespace authorization-rule keys list \
--resource-group testing \
--namespace-name cerebro-ingest-eh \
--name RootManageSharedAccessKey \
--query primaryConnectionString \
-o tsv

List Event Hubs in the Namespace

az eventhubs eventhub list \
--resource-group testing \
--namespace-name cerebro-ingest-eh \
--output table

Consumer Groups

az eventhubs eventhub consumer-group list \
--resource-group testing \
--namespace-name cerebro-ingest-eh \
--eventhub-name <hub-name> \
--output table

Checkpoints

The cerebrocheckpoints storage account stores Event Hub consumer group checkpoints. This allows the Router Service to resume from where it left off after a restart.