From azure-sdk-rust
Provides Rust code examples for Azure Event Hubs: create producers/consumers, send event batches, receive from partitions, get properties for streaming data ingestion.
npx claudepluginhub microsoft/skills --plugin azure-sdk-rustThis skill uses the workspace's default tool permissions.
Client library for Azure Event Hubs — big data streaming platform and event ingestion service.
Sends and receives events to Azure Event Hubs using Rust SDK. Manages producers, consumers, batches, partitions for streaming data ingestion.
Implements producers and consumers with Azure Event Hubs SDK for TypeScript. Handles event batching, partitioning, checkpointing, and subscription for high-throughput streaming and real-time data ingestion.
Implements Azure Event Hubs producers, consumers, and checkpointing in Python for high-throughput event streaming and ingestion.
Share bugs, ideas, or general feedback.
Client library for Azure Event Hubs — big data streaming platform and event ingestion service.
cargo add azure_messaging_eventhubs azure_identity
EVENTHUBS_HOST=<namespace>.servicebus.windows.net
EVENTHUB_NAME=<eventhub-name>
use azure_identity::DeveloperToolsCredential;
use azure_messaging_eventhubs::ProducerClient;
let credential = DeveloperToolsCredential::new(None)?;
let producer = ProducerClient::builder()
.open("<namespace>.servicebus.windows.net", "eventhub-name", credential.clone())
.await?;
producer.send_event(vec![1, 2, 3, 4], None).await?;
let batch = producer.create_batch(None).await?;
batch.try_add_event_data(b"event 1".to_vec(), None)?;
batch.try_add_event_data(b"event 2".to_vec(), None)?;
producer.send_batch(batch, None).await?;
use azure_messaging_eventhubs::ConsumerClient;
let credential = DeveloperToolsCredential::new(None)?;
let consumer = ConsumerClient::builder()
.open("<namespace>.servicebus.windows.net", "eventhub-name", credential.clone())
.await?;
// Open receiver for specific partition
let receiver = consumer.open_partition_receiver("0", None).await?;
// Receive events
let events = receiver.receive_events(100, None).await?;
for event in events {
println!("Event data: {:?}", event.body());
}
let properties = consumer.get_eventhub_properties(None).await?;
println!("Partitions: {:?}", properties.partition_ids);
let partition_props = consumer.get_partition_properties("0", None).await?;
println!("Last sequence number: {}", partition_props.last_enqueued_sequence_number);
try_add_event_data returns false when fullazure_messaging_eventhubs_checkpointstore_blob for distributed consumersFor distributed consumers with checkpointing:
cargo add azure_messaging_eventhubs_checkpointstore_blob