maruf-sherikar/antigravity-skills/azure-eventhub-rust

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);

cargo add azure_messaging_eventhubs_checkpointstore_blob