PulsarApache Pulsar - distributed pub-sub messaging system
Stars: ✭ 10,118 (+56111.11%)
tgipTGIP (TGI Pulsar) is a weekly live video streaming about Apache Pulsar and its ecosystem.
Stars: ✭ 17 (-5.56%)
LiftbridgeLightweight, fault-tolerant message streams.
Stars: ✭ 2,175 (+11983.33%)
Awesome PulsarA curated list of Pulsar tools, integrations and resources.
Stars: ✭ 57 (+216.67%)
liftbridge-apiProtobuf definitions for the Liftbridge gRPC API. https://github.com/liftbridge-io/liftbridge
Stars: ✭ 15 (-16.67%)
CentrifugoScalable real-time messaging server in a language-agnostic way. Set up once and forever.
Stars: ✭ 5,649 (+31283.33%)
aopAMQP on Pulsar protocol handler
Stars: ✭ 93 (+416.67%)
Pulsar DotpulsarThe official .NET client library for Apache Pulsar
Stars: ✭ 101 (+461.11%)
CentrifugeReal-time messaging library for Go with scalability in mind
Stars: ✭ 446 (+2377.78%)
EjabberdRobust, Ubiquitous and Massively Scalable Messaging Platform (XMPP, MQTT, SIP Server)
Stars: ✭ 5,077 (+28105.56%)
Hivemq Community EditionHiveMQ CE is a Java-based open source MQTT broker that fully supports MQTT 3.x and MQTT 5. It is the foundation of the HiveMQ Enterprise Connectivity and Messaging Platform
Stars: ✭ 562 (+3022.22%)
EmqxAn Open-Source, Cloud-Native, Distributed MQTT Message Broker for IoT.
Stars: ✭ 8,951 (+49627.78%)
HermesFast and reliable message broker built on top of Kafka.
Stars: ✭ 665 (+3594.44%)
Beaver💨 A real time messaging system to build a scalable in-app notifications, multiplayer games, chat apps in web and mobile apps.
Stars: ✭ 1,056 (+5766.67%)
Agile data code 2Code for Agile Data Science 2.0, O'Reilly 2017, Second Edition
Stars: ✭ 413 (+2194.44%)
Kafka Storm StarterCode examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.
Stars: ✭ 728 (+3944.44%)
gafkaA full ecosystem that is built around kafka powered by golang
Stars: ✭ 96 (+433.33%)
GaragemqAMQP message broker implemented with golang
Stars: ✭ 153 (+750%)
OryxOryx 2: Lambda architecture on Apache Spark, Apache Kafka for real-time large scale machine learning
Stars: ✭ 1,785 (+9816.67%)
firehoseFirehose is an extensible, no-code, and cloud-native service to load real-time streaming data from Kafka to data stores, data lakes, and analytical storage systems.
Stars: ✭ 213 (+1083.33%)
Nats.netThe official C# Client for NATS
Stars: ✭ 378 (+2000%)
Msngr.jsAn asynchronous messaging library, written in JavaScript, for node and the web browser
Stars: ✭ 337 (+1772.22%)
incubator-eventmeshEventMesh is a dynamic event-driven application runtime used to decouple the application and backend middleware layer, which supports a wide range of use cases that encompass complex multi-cloud, widely distributed topologies using diverse technology stacks.
Stars: ✭ 939 (+5116.67%)
pulsar-tracingTracing instrumentation for Apache Pulsar clients.
Stars: ✭ 13 (-27.78%)
LibzmqZeroMQ core engine in C++, implements ZMTP/3.1
Stars: ✭ 7,418 (+41111.11%)
Nats.rbRuby client for NATS, the cloud native messaging system.
Stars: ✭ 850 (+4622.22%)
SlimmessagebusLightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.
Stars: ✭ 120 (+566.67%)
amq-examplesThis repository contains a set of examples to be used with Red Hat AMQ messaging suite components.
Stars: ✭ 25 (+38.89%)
WirbelsturmWirbelsturm is a Vagrant and Puppet based tool to perform 1-click local and remote deployments, with a focus on big data tech like Kafka.
Stars: ✭ 332 (+1744.44%)
VernemqA distributed MQTT message broker based on Erlang/OTP. Built for high quality & Industrial use cases.
Stars: ✭ 2,628 (+14500%)
Tigase ServerHighly optimized, extremely modular and very flexible XMPP/Jabber server
Stars: ✭ 170 (+844.44%)
Spring StreamingSPA on Spring Boot 1.x, WebSockets and React, gradle, nodejs, spring-boot, gradle multi project, spring-mvc, spring-data, gradle dependency update plugin, react-router
Stars: ✭ 6 (-66.67%)
MobiusC# and F# language binding and extensions to Apache Spark
Stars: ✭ 929 (+5061.11%)
JockoKafka implemented in Golang with built-in coordination (No ZK dep, single binary install, Cloud Native)
Stars: ✭ 4,445 (+24594.44%)
Azure Event Hubs SparkEnabling Continuous Data Processing with Apache Spark and Azure Event Hubs
Stars: ✭ 140 (+677.78%)
Spark.NET for Apache® Spark™ makes Apache Spark™ easily accessible to .NET developers.
Stars: ✭ 1,721 (+9461.11%)
GraphikGraphik is a Backend as a Service implemented as an identity-aware document & graph database with support for gRPC and graphQL
Stars: ✭ 277 (+1438.89%)
Azure Event Hubs☁️ Cloud-scale telemetry ingestion from any stream of data with Azure Event Hubs
Stars: ✭ 233 (+1194.44%)
pulsar-flume-ng-sinkAn Apache Flume Sink implementation to publish data to Apache pulsar
Stars: ✭ 19 (+5.56%)
fink-brokerAstronomy Broker based on Apache Spark
Stars: ✭ 18 (+0%)
streamsx.kafkaRepository for integration with Apache Kafka
Stars: ✭ 13 (-27.78%)
DebeziumChange data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
Stars: ✭ 5,937 (+32883.33%)
KopKafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar
Stars: ✭ 159 (+783.33%)
Incubator HeronApache Heron (Incubating) is a realtime, distributed, fault-tolerant stream processing engine from Twitter
Stars: ✭ 3,571 (+19738.89%)
Data AcceleratorData Accelerator for Apache Spark simplifies onboarding to Streaming of Big Data. It offers a rich, easy to use experience to help with creation, editing and management of Spark jobs on Azure HDInsights or Databricks while enabling the full power of the Spark engine.
Stars: ✭ 247 (+1272.22%)
gobrokergolang wrapper for all (to-be) kinds of message brokers
Stars: ✭ 15 (-16.67%)
taleka Private Publish Subscribe System
Stars: ✭ 39 (+116.67%)