{"id":"7da82499-1c3e-4f21-8e2c-8dd5e5f0a23d","shortId":"TZFbN9","kind":"skill","title":"azure-eventhub-rust","tagline":"Azure Event Hubs SDK for Rust. Use for sending and receiving events, streaming data ingestion.","description":"# Azure Event Hubs SDK for Rust\n\nClient library for Azure Event Hubs — big data streaming platform and event ingestion service.\n\n## Installation\n\n```sh\ncargo add azure_messaging_eventhubs azure_identity\n```\n\n## Environment Variables\n\n```bash\nEVENTHUBS_HOST=<namespace>.servicebus.windows.net\nEVENTHUB_NAME=<eventhub-name>\n```\n\n## Key Concepts\n\n- **Namespace** — container for Event Hubs\n- **Event Hub** — stream of events partitioned for parallel processing\n- **Partition** — ordered sequence of events\n- **Producer** — sends events to Event Hub\n- **Consumer** — receives events from partitions\n\n## Producer Client\n\n### Create Producer\n\n```rust\nuse azure_identity::DeveloperToolsCredential;\nuse azure_messaging_eventhubs::ProducerClient;\n\nlet credential = DeveloperToolsCredential::new(None)?;\nlet producer = ProducerClient::builder()\n    .open(\"<namespace>.servicebus.windows.net\", \"eventhub-name\", credential.clone())\n    .await?;\n```\n\n### Send Single Event\n\n```rust\nproducer.send_event(vec![1, 2, 3, 4], None).await?;\n```\n\n### Send Batch\n\n```rust\nlet batch = producer.create_batch(None).await?;\nbatch.try_add_event_data(b\"event 1\".to_vec(), None)?;\nbatch.try_add_event_data(b\"event 2\".to_vec(), None)?;\n\nproducer.send_batch(batch, None).await?;\n```\n\n## Consumer Client\n\n### Create Consumer\n\n```rust\nuse azure_messaging_eventhubs::ConsumerClient;\n\nlet credential = DeveloperToolsCredential::new(None)?;\nlet consumer = ConsumerClient::builder()\n    .open(\"<namespace>.servicebus.windows.net\", \"eventhub-name\", credential.clone())\n    .await?;\n```\n\n### Receive Events\n\n```rust\n// Open receiver for specific partition\nlet receiver = consumer.open_partition_receiver(\"0\", None).await?;\n\n// Receive events\nlet events = receiver.receive_events(100, None).await?;\nfor event in events {\n    println!(\"Event data: {:?}\", event.body());\n}\n```\n\n### Get Event Hub Properties\n\n```rust\nlet properties = consumer.get_eventhub_properties(None).await?;\nprintln!(\"Partitions: {:?}\", properties.partition_ids);\n```\n\n### Get Partition Properties\n\n```rust\nlet partition_props = consumer.get_partition_properties(\"0\", None).await?;\nprintln!(\"Last sequence number: {}\", partition_props.last_enqueued_sequence_number);\n```\n\n## Best Practices\n\n1. **Reuse clients** — create once, send many events\n2. **Use batches** — more efficient than individual sends\n3. **Check batch capacity** — `try_add_event_data` returns false when full\n4. **Process partitions in parallel** — each partition can be consumed independently\n5. **Use consumer groups** — isolate different consuming applications\n6. **Handle checkpointing** — use `azure_messaging_eventhubs_checkpointstore_blob` for distributed consumers\n\n## Checkpoint Store (Optional)\n\nFor distributed consumers with checkpointing:\n\n```sh\ncargo add azure_messaging_eventhubs_checkpointstore_blob\n```\n\n## Reference Links\n\n| Resource | Link |\n|----------|------|\n| API Reference | https://docs.rs/azure_messaging_eventhubs |\n| Source Code | https://github.com/Azure/azure-sdk-for-rust/tree/main/sdk/eventhubs/azure_messaging_eventhubs |\n| crates.io | https://crates.io/crates/azure_messaging_eventhubs |\n\n## When to Use\nThis skill is applicable to execute the workflow or actions described in the overview.\n\n## Limitations\n- Use this skill only when the task clearly matches the scope described above.\n- Do not treat the output as a substitute for environment-specific validation, testing, or expert review.\n- Stop and ask for clarification if required inputs, permissions, safety boundaries, or success criteria are missing.","tags":["azure","eventhub","rust","antigravity","awesome","skills","sickn33","agent-skills","agentic-skills","ai-agent-skills","ai-agents","ai-coding"],"capabilities":["skill","source-sickn33","skill-azure-eventhub-rust","topic-agent-skills","topic-agentic-skills","topic-ai-agent-skills","topic-ai-agents","topic-ai-coding","topic-ai-workflows","topic-antigravity","topic-antigravity-skills","topic-claude-code","topic-claude-code-skills","topic-codex-cli","topic-codex-skills"],"categories":["antigravity-awesome-skills"],"synonyms":[],"warnings":[],"endpointUrl":"https://skills.sh/sickn33/antigravity-awesome-skills/azure-eventhub-rust","protocol":"skill","transport":"skills-sh","auth":{"type":"none","details":{"cli":"npx skills add sickn33/antigravity-awesome-skills","source_repo":"https://github.com/sickn33/antigravity-awesome-skills","install_from":"skills.sh"}},"qualityScore":"0.700","qualityRationale":"deterministic score 0.70 from registry signals: · indexed on github topic:agent-skills · 34928 github stars · SKILL.md body (3,541 chars)","verified":false,"liveness":"unknown","lastLivenessCheck":null,"agentReviews":{"count":0,"score_avg":null,"cost_usd_avg":null,"success_rate":null,"latency_p50_ms":null,"narrative_summary":null,"summary_updated_at":null},"enrichmentModel":"deterministic:skill-github:v1","enrichmentVersion":1,"enrichedAt":"2026-04-24T18:50:30.536Z","embedding":null,"createdAt":"2026-04-18T21:32:27.113Z","updatedAt":"2026-04-24T18:50:30.536Z","lastSeenAt":"2026-04-24T18:50:30.536Z","tsv":"'/azure/azure-sdk-for-rust/tree/main/sdk/eventhubs/azure_messaging_eventhubs':352 '/azure_messaging_eventhubs':347 '/crates/azure_messaging_eventhubs':356 '0':205,251 '1':126,147,264 '100':214 '2':127,157,272 '3':128,280 '4':129,292 '5':303 '6':311 'action':369 'add':43,142,152,285,333 'api':343 'applic':310,363 'ask':407 'await':118,131,140,165,191,207,216,236,253 'azur':2,5,20,29,44,47,95,99,172,315,334 'azure-eventhub-rust':1 'b':145,155 'bash':51 'batch':133,136,138,162,163,274,282 'batch.try':141,151 'best':262 'big':32 'blob':319,338 'boundari':415 'builder':111,184 'capac':283 'cargo':42,332 'check':281 'checkpoint':313,323,330 'checkpointstor':318,337 'clarif':409 'clear':382 'client':26,90,167,266 'code':349 'concept':58 'consum':84,166,169,182,301,305,309,322,328 'consumer.get':232,248 'consumer.open':202 'consumercli':175,183 'contain':60 'crates.io':353,355 'crates.io/crates/azure_messaging_eventhubs':354 'creat':91,168,267 'credenti':104,177 'credential.clone':117,190 'criteria':418 'data':18,33,144,154,223,287 'describ':370,386 'developertoolscredenti':97,105,178 'differ':308 'distribut':321,327 'docs.rs':346 'docs.rs/azure_messaging_eventhubs':345 'effici':276 'enqueu':259 'environ':49,398 'environment-specif':397 'event':6,16,21,30,37,62,64,68,77,80,82,86,121,124,143,146,153,156,193,209,211,213,218,220,222,226,271,286 'event.body':224 'eventhub':3,46,52,55,101,115,174,188,233,317,336 'eventhub-nam':114,187 'execut':365 'expert':403 'fals':289 'full':291 'get':225,241 'github.com':351 'github.com/azure/azure-sdk-for-rust/tree/main/sdk/eventhubs/azure_messaging_eventhubs':350 'group':306 'handl':312 'host':53 'hub':7,22,31,63,65,83,227 'id':240 'ident':48,96 'independ':302 'individu':278 'ingest':19,38 'input':412 'instal':40 'isol':307 'key':57 'last':255 'let':103,108,135,176,181,200,210,230,245 'librari':27 'limit':374 'link':340,342 'mani':270 'match':383 'messag':45,100,173,316,335 'miss':420 'name':56,116,189 'namespac':59 'new':106,179 'none':107,130,139,150,160,164,180,206,215,235,252 'number':257,261 'open':112,185,195 'option':325 'order':74 'output':392 'overview':373 'parallel':71,296 'partit':69,73,88,199,203,238,242,246,249,294,298 'partition_props.last':258 'permiss':413 'platform':35 'practic':263 'println':221,237,254 'process':72,293 'produc':78,89,92,109 'producer.create':137 'producer.send':123,161 'producercli':102,110 'prop':247 'properti':228,231,234,243,250 'properties.partition':239 'receiv':15,85,192,196,201,204,208 'receiver.receive':212 'refer':339,344 'requir':411 'resourc':341 'return':288 'reus':265 'review':404 'rust':4,10,25,93,122,134,170,194,229,244 'safeti':414 'scope':385 'sdk':8,23 'send':13,79,119,132,269,279 'sequenc':75,256,260 'servic':39 'servicebus.windows.net':54,113,186 'sh':41,331 'singl':120 'skill':361,377 'skill-azure-eventhub-rust' 'sourc':348 'source-sickn33' 'specif':198,399 'stop':405 'store':324 'stream':17,34,66 'substitut':395 'success':417 'task':381 'test':401 'topic-agent-skills' 'topic-agentic-skills' 'topic-ai-agent-skills' 'topic-ai-agents' 'topic-ai-coding' 'topic-ai-workflows' 'topic-antigravity' 'topic-antigravity-skills' 'topic-claude-code' 'topic-claude-code-skills' 'topic-codex-cli' 'topic-codex-skills' 'treat':390 'tri':284 'use':11,94,98,171,273,304,314,359,375 'valid':400 'variabl':50 'vec':125,149,159 'workflow':367","prices":[{"id":"696a570e-0f01-4a1b-b306-c6a5e283450c","listingId":"7da82499-1c3e-4f21-8e2c-8dd5e5f0a23d","amountUsd":"0","unit":"free","nativeCurrency":null,"nativeAmount":null,"chain":null,"payTo":null,"paymentMethod":"skill-free","isPrimary":true,"details":{"org":"sickn33","category":"antigravity-awesome-skills","install_from":"skills.sh"},"createdAt":"2026-04-18T21:32:27.113Z"}],"sources":[{"listingId":"7da82499-1c3e-4f21-8e2c-8dd5e5f0a23d","source":"github","sourceId":"sickn33/antigravity-awesome-skills/azure-eventhub-rust","sourceUrl":"https://github.com/sickn33/antigravity-awesome-skills/tree/main/skills/azure-eventhub-rust","isPrimary":false,"firstSeenAt":"2026-04-18T21:32:27.113Z","lastSeenAt":"2026-04-24T18:50:30.536Z"}],"details":{"listingId":"7da82499-1c3e-4f21-8e2c-8dd5e5f0a23d","quickStartSnippet":null,"exampleRequest":null,"exampleResponse":null,"schema":null,"openapiUrl":null,"agentsTxtUrl":null,"citations":[],"useCases":[],"bestFor":[],"notFor":[],"kindDetails":{"org":"sickn33","slug":"azure-eventhub-rust","github":{"repo":"sickn33/antigravity-awesome-skills","stars":34928,"topics":["agent-skills","agentic-skills","ai-agent-skills","ai-agents","ai-coding","ai-workflows","antigravity","antigravity-skills","claude-code","claude-code-skills","codex-cli","codex-skills","cursor","cursor-skills","developer-tools","gemini-cli","gemini-skills","kiro","mcp","skill-library"],"license":"mit","html_url":"https://github.com/sickn33/antigravity-awesome-skills","pushed_at":"2026-04-24T06:41:17Z","description":"Installable GitHub library of 1,400+ agentic skills for Claude Code, Cursor, Codex CLI, Gemini CLI, Antigravity, and more. Includes installer CLI, bundles, workflows, and official/community skill collections.","skill_md_sha":"97f05b6279e46a60ec4f50215a67a8dbba293398","skill_md_path":"skills/azure-eventhub-rust/SKILL.md","default_branch":"main","skill_tree_url":"https://github.com/sickn33/antigravity-awesome-skills/tree/main/skills/azure-eventhub-rust"},"layout":"multi","source":"github","category":"antigravity-awesome-skills","frontmatter":{"name":"azure-eventhub-rust","description":"Azure Event Hubs SDK for Rust. Use for sending and receiving events, streaming data ingestion."},"skills_sh_url":"https://skills.sh/sickn33/antigravity-awesome-skills/azure-eventhub-rust"},"updatedAt":"2026-04-24T18:50:30.536Z"}}