#
event-hubs
Here are 41 public repositories matching this topic...
Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs
microsoft
streaming
real-time
scala
kafka
spark
apache-spark
stream
connector
azure
bigdata
apache
spark-streaming
eventhubs
ingestion
continuous
event-hubs
databricks
structured-streaming
-
Updated
Dec 9, 2021 - Scala
Azure Event Hubs for Apache Kafka Ecosystems
-
Updated
Jan 14, 2022 - Java
-
Updated
Feb 9, 2022 - C#
Golang client library for Azure Event Hubs https://azure.microsoft.com/services/event-hubs
-
Updated
Mar 30, 2022 - Go
Accessing Azure services (App Service, Table Storage, CosmosDB with Table API, Event Hubs) from a Unity game
unity
storage
azure
table-storage
appservice
event-hubs
unity-game
mobileapps
cosmosdb
azure-services
-
Updated
Feb 7, 2018 - C#
SQL Server Change Stream sample using Debezium
sql-server
kafka
azure-functions
event-hubs
cdc
change-data-capture
debezium
change-feed
azure-sql
change-streams
-
Updated
Mar 17, 2022 - C#
-
Updated
Jan 4, 2022 - Java
Uses Durable Functions' fan out pattern to load N messages across M sessions into various Azure Storage/Messaging services. Includes the ability to consume the messages with another Azure Function & load timing data in to Event Hubs for ingestion in to analytics services like Azure Data Explorer
-
Updated
Sep 24, 2021 - C#
Sample Inventory Hub App using Serverless and Event-driven Java - on Azure with Spring Boot, Tomcat, Functions, Event Hub and Cosmos DB
-
Updated
Jul 15, 2021 - Java
Connect Splunk to Azure Activity Log via PowerShell automation
-
Updated
Oct 13, 2018 - PowerShell
Azure AMQP abstractions for Golang contains common types and interfaces for use in Service Bus and Event Hubs.
-
Updated
Dec 7, 2021 - Go
Open
메시지 예약 도우미 메서드 추가
gyuwon
commented
Oct 15, 2017
Envelope 형식을 ScheduledEnvelope 형식으로 포장하는 도우미 메서드를 추가합니다.
예약 시각
var envelope = new Envelope(new SomeCommand());
// 내일 자정에 발행
ScheduledEnvelope scheduled = envelope.Schedule(DateTime.Today.AddDay(1));지연 시간
var envelope = new Envelope(new SomeCommand());
// 15분 후에 발행
ScheduledEnvelope delayed = envelope.Delay(TimeSpan.FromMinutes(15));
good first issue
Good for newcomers
Use Azure Event Hubs as a remote storage for Prometheus
-
Updated
Feb 1, 2022 - Go
SemanticLogging.EventHub is a collection of sinks for the Semantic Logging Application Block that exposes Event Source events to an Azure Event Hub.
azure
logging
structured-logging
etw
eventsource
event-hubs
azure-event-hub
semantic-logging
azure-eventhub
azure-event-hubs
-
Updated
Dec 7, 2018 - C#
useful tools to debug application which uses azure event hubs
-
Updated
Jan 20, 2022 - Go
Weltraum TDRS is a lightweight ZeroMQ-based event hub.
-
Updated
Oct 29, 2016 - C++
Big data reference architecture and implementation for an online multiplayer game
-
Updated
Apr 9, 2022 - JavaScript
Azure Service Bus / Event Hub Load Generator
generator
azure
service-bus
load-testing
event-hubs
load-generator
service-bus-queue
service-bus-topic
event-hub
-
Updated
Nov 13, 2018 - C#
TDRS Node.js client reference implementation
nodejs
socket
events
node
zeromq
messaging
message-bus
hub
eventbus
node-module
event-hubs
client-library
tdrs
-
Updated
Nov 23, 2016 - JavaScript
Golang easy to use library to send and receive event hubs events.
-
Updated
Mar 11, 2021 - Go
This sample shows how to use configure a virtual network and Private DNS Zone to access a Event Hubs namespace via a Private Endpoint.
azure
virtual-machine
azure-storage
event-hubs
azure-storage-account
virtual-network
azure-storage-blob
storage-account
private-link
azure-virtual-networks
private-dns-zone
private-endpoint
event-hubs-namespace
-
Updated
Jul 30, 2020 - Shell
Minimal example using Spring Boot and Spring Kafka to connect to Azure Event Hubs
-
Updated
Jun 3, 2018 - Java
Use Redis for the Checkpoint and Lease manager with Azure Event Processor Host (EPH) in Java
-
Updated
Oct 14, 2020 - Java
Azure AMQP abstractions for javascript/typescript that contains common types and interfaces for use in Service Bus and Event Hubs.
-
Updated
Jun 26, 2019 - TypeScript
Event Hub for for event-based applications
-
Updated
Feb 11, 2022 - TypeScript
Sample that uses Event Hubs to ingest streaming Diagnostic Logs from Azure Virtual Machines. Azure Functions is configured as the Event Hub Consumer that logs the incoming log stream
-
Updated
Aug 20, 2018 - C#
Android Publisher/Subscriber library for lazy people
-
Updated
Oct 30, 2017 - Java
Improve this page
Add a description, image, and links to the event-hubs topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the event-hubs topic, visit your repo's landing page and select "manage topics."
In what area(s)?
/area components (kafka pub/sub)
Describe the feature
The current kafka pub/sub component targets just the minimum interfaces to publish and subscribe. We need an enhancement to the kafka component to support "ResetOffets". This means, we need to be able to invoke an API call to the dapr sidecar to "reset" the current offset to a previous value so that messages can b