Azure Event Hubs Endpoint

Consume and produce event streams from Event Hubs with partition controls.

Consumer Groups

Use dedicated consumer groups for predictable test isolation.

Feature Usage Samples

How to use snippets for Azure Event Hubs Endpoint.

Switch between C#, Java, Python, TypeScript, and JavaScript to see the native SDK shape for this sample.

Licensing note: every runnable sample requires a valid runner key via WithRunnerKey("...") or config key LoadStrike:RunnerKey.

Event Hubs Endpoint

var endpoint = new AzureEventHubsEndpointDefinition
{
    Name = "eh-out",
    Mode = TrafficEndpointMode.Consume,
    TrackingField = TrackingFieldSelector.Parse("json:$.trackingId"),
    ConnectionString = "<connection-string>",
    EventHubName = "orders"
};

import com.loadstrike.runtime.AzureEventHubsEndpointDefinition;
import com.loadstrike.runtime.LoadStrikeCorrelation.TrackingFieldSelector;
import com.loadstrike.runtime.LoadStrikeTransports;

var endpoint = new AzureEventHubsEndpointDefinition();
endpoint.name = "eh-out";
endpoint.mode = LoadStrikeTransports.TrafficEndpointMode.Consume;
endpoint.trackingField = TrackingFieldSelector.parse("json:$.trackingId");
endpoint.connectionString = "<connection-string>";
endpoint.eventHubName = "orders";

from loadstrike_sdk import AzureEventHubsEndpointDefinition, TrackingFieldSelector

endpoint = AzureEventHubsEndpointDefinition(
    name="eh-out",
    mode="Consume",
    tracking_field=TrackingFieldSelector.parse("json:$.trackingId"),
    connection_string="<connection-string>",
    event_hub_name="orders",
)

import { AzureEventHubsEndpointDefinition, TrackingFieldSelector } from "@loadstrike/loadstrike-sdk";

const endpoint = new AzureEventHubsEndpointDefinition({
  name: "eh-out",
  mode: "Consume",
  trackingField: TrackingFieldSelector.parse("json:$.trackingId"),
  connectionString: "<connection-string>",
  eventHubName: "orders"
});

const { AzureEventHubsEndpointDefinition, TrackingFieldSelector } = require("@loadstrike/loadstrike-sdk");

const endpoint = new AzureEventHubsEndpointDefinition({
  name: "eh-out",
  mode: "Consume",
  trackingField: TrackingFieldSelector.parse("json:$.trackingId"),
  connectionString: "<connection-string>",
  eventHubName: "orders"
});

Body Example

ConnectionString

Specifies how the adapter connects to the Event Hubs namespace.

EventHubName

Specifies which Event Hub the adapter should write to or read from.

PartitionId

Optionally targets a specific partition for consumer-side reads.

TrackingField

Points to the header or body field that carries the correlation id.

{ "trackingId": "trk-1" }

Azure Event Hubs Endpoint

Consumer Groups

Feature Usage Samples

Event Hubs Endpoint

Body Example

Diagram