Awesome Open Source
Search
Programming Languages
Languages
All Categories
Categories
About
Search results for java pubsub
java
x
pubsub
x
79 search results found
Kafdrop
⭐
5,004
Kafka Web UI
Autobahn Java
⭐
1,512
WebSocket & WAMP in Java for Android and Java 8
Dataflowtemplates
⭐
1,060
Cloud Dataflow Google-provided templates for solving in-Cloud data tasks
Hivemq Community Edition
⭐
1,008
HiveMQ 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
Jdonframework
⭐
877
Domain-Driven-Design Pub/Sub Domain-Events framework
Hermes
⭐
778
Fast and reliable message broker built on top of Kafka.
Kop
⭐
439
Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar
Twitch4j
⭐
361
Modular Async/Sync/Reactive Twitch API Client / IRC Client
Tigase Server
⭐
307
(M) Highly optimized, extremely modular and very flexible XMPP/Jabber server
Nybus
⭐
284
NYBus (RxBus) - A pub-sub library for Android and Java applications
Divolte Collector
⭐
275
Divolte Collector
Async Google Pubsub Client
⭐
153
[SUNSET] Async Google Pubsub Client
Jpost
⭐
117
Java and Android class communication library: New and improved Pub-Sub
Java Pubsub
⭐
112
Module Ballerina Mqtt
⭐
110
Ballerina MQTT Module.
Aop
⭐
107
AMQP on Pulsar protocol handler
Pub Sub Api
⭐
94
Sample project to get started with the Pub/Sub API
Df Ml Anomaly Detection
⭐
69
Streaming Anomaly Detection Solution by using Pub/Sub, Dataflow, BQML & Cloud DLP
Memq
⭐
66
MemQ is an efficient, scalable cloud native PubSub system
Elasticsearch Redis River
⭐
64
A Redis River for Elastic Search.
Pubsub To Bigquery
⭐
64
A highly configurable Google Cloud Dataflow pipeline that writes data into Google Big Query table from Pub/Sub
Netty Pubsub
⭐
58
百万级高性能分布式发布订阅系统,基于nio,netty开发,无锁并发,充分发挥cpu极限, 该项目已自带心跳检测功能,断线自动重连,非常稳定。 注意该项目软件编码为GBK,导入的时候一定要看清项目编码格式。
Connectorplugin
⭐
52
Plugin to simplify communication between multiple Minecraft servers (and proxies) in a network. Supports plugin messages, redis and MQTT (e.g. using RabbitMQ or Google Cloud. MQTT is untested rn!). RedisBungee alternative.
Cloud Dataflow Nyc Taxi Tycoon
⭐
45
This is the support code and solutions for the NYC Taxi Tycoon Dataflow Codelab
Google Cloud
⭐
42
A collection of Google Cloud Platform (GCP) plugins
Bullet Storm
⭐
39
The Apache Storm implementation of the Bullet backend
Gameanalytics
⭐
39
A fully-managed pipeline for game analytics
Hanbo Db
⭐
33
hanboDB is a high available,low latency memory database system
Cloud Pubsub Mqtt Proxy
⭐
31
A proxy between Cloud Pub/Sub and MQTT
Dataflow Video Analytics
⭐
30
Video Clip Analytics By Using Dataflow and Video AI For Object Tracking
Solace Samples Cloudfoundry Java
⭐
28
Samples showing how to connect and exchange messages with Solace Messaging for Pivotal Cloud Foundry.
Java Pubsublite
⭐
27
Aws Sqs Consumer
⭐
24
The AWS SQS Consumer reduces time to launch a SQS Message Consumer, by empowering developers to focus on business logic of consuming the message.
Spark On K8s Gcp Examples
⭐
24
Example Spark applications that run on Kubernetes and access GCP products, e.g., GCS, BigQuery, and Cloud PubSub
Reactor Pubsub
⭐
24
Google Pub/Sub Java driver for mortals.
Spanner Change Watcher
⭐
24
Cloud Spanner Change Watcher and Publisher - Detects data changes in Cloud Spanner databases
Pulsar Io Kafka
⭐
24
Pulsar IO Kafka Connector
Pulsar Adapters
⭐
23
Apache Pulsar Adapters
Play Akka Cluster Pub Sub
⭐
23
In this sample i integrate a play framework app (java) with akka cluster so that you can easily add new play node to scale your system. when a new node added all node in the cluster log hello message, no matter which node receives the message.
Raycom
⭐
21
Apache Beam Sample, use master branch as a java skeleton project.
Meteor
⭐
19
Real-time message streaming over a Hazelcast in-memory data grid
Smartacus Mqtt Broker
⭐
19
smartacus-mqtt-broker is a Java-based open source MQTT broker that fully supports MQTT 3.x .Using Netty 4.1.37
Pubsubplus Connector Kafka Source
⭐
18
Source connector to send data from Solace message broker to Apache Kafka streaming platform
Butterknifelite
⭐
17
View binding library
Faye.java
⭐
16
A Faye client for Java 1.6+
Pulsar Tracing
⭐
16
Tracing instrumentation for Apache Pulsar clients.
Pulsar Flume Ng Sink
⭐
16
An Apache Flume Sink implementation to publish data to Apache pulsar
Solace Samples Spring
⭐
16
Developer Samples for using Solace PubSub+ with Spring Framework
Demo_springboot
⭐
12
SpringBoot学习相关示例
Tinyeventbus
⭐
12
Tiny and fast pubsub implementation with subscriber priorities and event canceling for Java 8, 11 and 17.
Glitch
⭐
12
!NO MORE MAINTAINED! Reactive API Wrapper for Twitch in Kotlin/JVM
Pubsub Android
⭐
12
Jmeter Pubsub Sampler
⭐
11
JMeter plugin to Publish and Subscribe Messages to GCP
Spark Pubsub
⭐
11
Google Cloud Pubsub connector for Spark Streaming
Xoom Streams
⭐
11
The VLINGO XOOM platform SDK for Reactive Streams built on XOOM ACTORS.
Fdb Pubsub
⭐
10
Pub/Sub built on top of FoundationDB
Txpb
⭐
10
TemporalX gRPC and Documentation Resources
Ffs Pubsub
⭐
10
Fight For Sub PubSub server
Andriot
⭐
9
Android Things application for Raspberry Pi 3
Dataflow Bigquery Dynamic Destinations
⭐
9
An example pipeline for dynamically routing events from Pub/Sub to different BigQuery tables based on a message attribute.
Jms 1.1 Pubsub Queue Example With Activemq
⭐
8
JMS-1.1-PubSub-Queue-Example-with-ActiveMQ
Magnolia
⭐
8
PubSub utilities and dynamic plugin testing for neo4j
Hedera Etl
⭐
8
ETL scripts for Hedera Hashgraph
Pulsar Recipes
⭐
8
A StreamNative library containing a collection of recipes that are implemented on top of the Pulsar client to provide higher-level functionality closer to the application domain.
Twitch4j Minecraft Plugin
⭐
8
Bukkit Plugin Template with Twitch API Integration for Minecraft Servers, powered by Twitch4J
Osgi Messaging
⭐
8
OSGi Messaging Specification RFC 246 and compliant MQTT 5.0 Implementation
Vertx Async To Sync
⭐
8
Consume an async api (with callback) from sync endpoint using vert.x
Jasync
⭐
7
Lightweight developer friendly framework for asynchronous tasks and messaging
Smackx Pubsub
⭐
7
[RETIRED -- now in SVN trunk] XEP-0060 extension to the Smack XMPP client library
Kafka Connect Pubsub
⭐
6
Kafka source connector for google pubsub
Pubsubplus Connector Kafka Sink
⭐
6
Sink connector to recieve data from Apache Kafka streaming platform and send to Solace message broker
Java Liftbridge
⭐
6
Java client for Liftbridge. https://github.com/liftbridge-io/liftbridge
Datapipeline
⭐
6
Data pipeline
Dataflowsme
⭐
6
Tutorial for Cloud Dataflow
Mqtt Tree
⭐
6
A quick and efficient data structure for indexing MQTT subscriptions in a highly concurrent environment.
Bullet Pulsar
⭐
6
The Apache Pulsar PubSub implementation pluggable into the Bullet Service and Backend
Simplepubsub
⭐
6
Simple pubsub implementation using core JAVA with no external dependencies
Hdm Wim Devlab
⭐
5
Python Realtimemagic
⭐
5
WorkInProgress. A set of tools to make writting a realtime sockjs server easy(er)
Pubsub
⭐
5
Infrastructure for pubsub messaging
Pubsub Java
⭐
5
pubsub.io java client
Simpleventbus
⭐
5
Simple EventBus/PubSub implementations for demos/tests/etc (Not for production)
Bullet Kafka
⭐
5
The Apache Kafka PubSub implementation pluggable into the Bullet Service and Backend
Content Dicovery Platform Gcp
⭐
5
A content discovery platform powered by LLMs
Nifi Redis Pubsub Bundle
⭐
5
NiFi processor emulating queue/topic patterns on top of Redis
Pubsub Integration Testing
⭐
5
A project demonstrating how to integration test interactions with Google Pub/Sub
Lagom Google Pubsub
⭐
5
Google Pub/Sub integration for Lagom message broker API
Related Searches
Java Spring (21,350)
Java Spring Boot (11,982)
Java Video Game (8,093)
Java Gradle (8,086)
Java Docker (6,071)
Java Database (6,015)
Java Mysql (5,954)
Javascript Java (5,921)
Java Sdk (5,864)
Java Rest (4,956)
1-79 of 79 search results
Privacy
|
About
|
Terms
|
Follow Us On Twitter
Copyright 2018-2024 Awesome Open Source. All rights reserved.