Filter By
79 Repositories
Java Messaging
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
Aeron Efficient reliable UDP unicast, UDP multicast, and IPC message transport. Java and C++ clients are available in this repository, and a .NET clie
Pure Java ZeroMQ
JeroMQ Pure Java implementation of libzmq (http://zeromq.org). Features Based on libzmq 4.1.7. ZMTP/3.0 (http://rfc.zeromq.org/spec:23). tcp:// protoc
High Performance Inter-Thread Messaging Library
LMAX Disruptor A High Performance Inter-Thread Messaging Library Maintainer LMAX Development Team Support Open a ticket in GitHub issue tracker Google
RabbitMQ Java client
RabbitMQ Java Client This repository contains source code of the RabbitMQ Java client. The client is maintained by the RabbitMQ team at Pivotal. Depen
Powerful event-bus optimized for high throughput in multi-threaded applications. Features: Sync and Async event publication, weak/strong references, event filtering, annotation driven
MBassador MBassador is a light-weight, high-performance event bus implementing the publish subscribe pattern. It is designed for ease of use and aims
Mirror of Apache Kafka
Apache Kafka See our web site for details on the project. You need to have Java installed. We build and test Apache Kafka with Java 8, 11 and 15. We s
Java client for NATS
NATS - Java Client A Java client for the NATS messaging system. A Note on Versions This is version 2.x of the java-nats library. This version is a gro
Apache Pulsar - distributed pub-sub messaging system
Pulsar is a distributed pub-sub messaging platform with a very flexible messaging model and an intuitive client API. Learn more about Pulsar at https:
RocketMQ-on-Pulsar - A protocol handler that brings native RocketMQ protocol to Apache Pulsar
RocketMQ on Pulsar(RoP) RoP stands for RocketMQ on Pulsar. Rop broker supports RocketMQ-4.6.1 protocol, and is backed by Pulsar. RoP is implemented as
Kryptonite is a turn-key ready transformation (SMT) for Apache Kafka® Connect to do field-level 🔒 encryption/decryption 🔓 of records. It's an UNOFFICIAL community project.
Kryptonite - An SMT for Kafka Connect Kryptonite is a turn-key ready transformation (SMT) for Apache Kafka® to do field-level encryption/decryption of
Event bus for Android and Java that simplifies communication between Activities, Fragments, Threads, Services, etc. Less code, better quality.
EventBus EventBus is a publish/subscribe event bus for Android and Java. EventBus... simplifies the communication between components decouples event s
Fast and reliable message broker built on top of Kafka.
Hermes Hermes is an asynchronous message broker built on top of Kafka. We provide reliable, fault tolerant REST interface for message publishing and a
Open data platform based on flink. Now scaleph is supporting data integration with seatunnel on flink
scaleph The Scaleph project features data integration, develop, job schedule and orchestration and trys to provide one-stop data platform for develope
An XMPP server licensed under the Open Source Apache License.
Openfire About Openfire is a real time collaboration (RTC) server licensed under the Open Source Apache License. It uses the only widely adopted open
Mirror of Apache ActiveMQ
Welcome to Apache ActiveMQ Apache ActiveMQ is a high performance Apache 2.0 licensed Message Broker and JMS 1.1 implementation. Getting Started To hel
SeaTunnel is a distributed, high-performance data integration platform for the synchronization and transformation of massive data (offline & real-time).
SeaTunnel SeaTunnel was formerly named Waterdrop , and renamed SeaTunnel since October 12, 2021. SeaTunnel is a very easy-to-use ultra-high-performanc
Apache Camel is an open source integration framework that empowers you to quickly and easily integrate various systems consuming or producing data.
Apache Camel Apache Camel is a powerful, open-source integration framework based on prevalent Enterprise Integration Patterns with powerful bean integ
MemQ is a new PubSub system that augments Kafka
MemQ: An efficient, scalable cloud native PubSub system MemQ is a new PubSub system that augments Kafka at Pinterest. It uses a decoupled storage and
A modular and portable open source XMPP client library written in Java for Android and Java (SE) VMs
Smack About Smack is an open source, highly modular, easy to use, XMPP client library written in Java for Java SE compatible JVMs and Android. A pure
Kafka is not for event sourcing, isn't it? Kafka alone is not an event store, but Kafka and ksqlDB together allow building full-featured event stores. This repository provides a sample of event sourced system that uses Kafka and ksqlDB as event store.
Event Sourcing with Kafka and ksqlDB Introduction Example Domain Event Sourcing and CQRS 101 State-Oriented Persistence Event Sourcing CQRS Advantages
Mirror of Apache RocketMQ
Apache RocketMQ Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level c
Mirror of Apache ActiveMQ Artemis
ActiveMQ Artemis This file describes some minimum 'stuff one needs to know' to get started coding in this project. Source For details about the modify
2021年更新开源数字货币合约交易所，基于Java开发的比特币交易所 | BTC交易所 | ETH交易所 | 数字货币交易所 | 交易平台 | 撮合交易引擎。本项目有完整的撮合交易引擎源码、后台管理（后端+前端）、前台（交易页面、活动页面、个人中心等）、安卓APP源码、苹果APP源码、币种钱包RPC源码。开源项目仅供学习参考，请勿用于非法用途
一、项目目标 安卓+IOS+PC+钱包 2021年新版更新 ZTuo数字资产交易平台（以下简称“ZTuo”）是ZTuo团队历经了多个数字资产交易系统开发之后，通过不断的优化精简，首家开源的Java语言开发的数字货币交易所平台，支持当前多种主流的数字货币交易（测试环境受限于服务器的成本，目前支持USD
ASTM 1394 implements CLSI LIS2-A2 (formerly ASTM E1394)
ASTM 1394 реализует стандарт CLSI LIS2-A2 (ранее ASTM E1394)
A VPN app made with Jetpack Compose.
Gear VPN - Free, Secure & Open sourced VPN Tech Stack Jetpack Compose - Google's new UI toolkit for developing native Android apps. Navigator-Compose
Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.
Dagger Dagger or Data Aggregator is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processi
这是一个基于Xposed的抖音插件
xposed-dy 基于Xposed的抖音爬虫 主要功能列表 采集指定达人最新视频的评论 done 采集指定视频的评论 done 采集直播间互动消息 done 采集直播间礼物消息 done dy限制后自动重启 done dy风控后一键新机、清除缓存 doing 支持与服务器交互 done 获取指定的
Firehose 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.
Firehose - Firehose 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.
A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues
Nakadi Event Broker Nakadi is a distributed event bus broker that implements a RESTful API abstraction on top of Kafka-like queues, which can be used
A command line client for Kafka Connect
🧸 kcctl – Your Cuddly CLI for Apache Kafka Connect This project is a command-line client for Kafka Connect. Relying on the idioms and semantics of ku
A command line client for Kafka Connect
kcctl -- A CLI for Apache Kafka Connect This project is a command-line client for Kafka Connect. Relying on the idioms and semantics of kubectl, it al
Real Time communication library using Animated Gifs as a transport™
gifsockets "This library is the websockets of the '90s" - Somebody at Hacker News. This library shows how to achieve realtime text communication using
SMS app based on QKSMS. DISCLAIMER: This project is intended for my own use. No issues are accepted
Messages Messages is an open source replacement to the stock messaging app on Android. DISCLAIMER: Unlike most other projects, this project is for my
EventStoreDB is the database for Event Sourcing. This repository provides a sample of event sourced system that uses EventStoreDB as event store.
Event Sourcing with EventStoreDB Introduction Example Domain Event Sourcing and CQRS 101 State-Oriented Persistence Event Sourcing CQRS Advantages of
An Open-Source, Distributed MQTT Message Broker for IoT.
MMQ broker MMQ broker 是一款完全开源，高度可伸缩，高可用的分布式 MQTT 消息服务器，适用于 IoT、M2M 和移动应用程序。 MMQ broker 完整支持MQTT V3.1 和 V3.1.1。 安装 MMQ broker 是跨平台的，支持 Linux、Unix、macOS
MC Protocol specification of the current minecraft release / snapshot. Most useful when developing with ProtocolLib.
Snapshot 1.19.1-pre4 (1.19.1), Protocol 97 (1073741921), Release Protocol: 760 Handshaking (Server - Client) Handshaking (Client - Server) 0x00 - Cl
A high available,high performance distributed messaging system.
#新闻 MetaQ 1.4.6.2发布。更新日志 MetaQ 1.4.6.1发布。更新日志 MetaQ 1.4.5.1发布。更新日志 MetaQ 1.4.5发布。更新日志 Meta-ruby 0.1 released: a ruby client for metaq. SOURCE #介绍 Meta
Java binding for ZeroMQ
What is JZMQ? This is the Java language binding for libzmq (aka ZeroMQ, 0MQ). The latest javadocs. Building and Installing JZMQ To build you need to h
This repository contains a functional example of an order delivery service similar to UberEats, DoorDash, and Instacart.
Order Delivery Microservice Example In an event-driven microservices architecture, the concept of a domain event is central to the behavior of each se
CookieClient is a utility client for anarchy servers
CookieClient CookieClient is a utility client for anarchy servers. Its a forge mod so you need forge to run it. Currently supported versions: 1.12.2 D
Flink Demo
flink-demo minimum code just run flink-ds-connector DataStream API usage kafka es jdbc file row string parquet avro avro custom avro flink-sql-connect
HornetQ is an open source project to build a multi-protocol, embeddable, very high performance, clustered, asynchronous messaging system.
HornetQ If you need information about the HornetQ project please go to http://community.jboss.org/wiki/HornetQ http://www.jboss.org/hornetq/ This file
Sometimes people say that playing on anarchy servers far away from spawn is like Singleplayer with chat, so this mod just makes the exact thing possible.
Singleplayer With Chat Sometimes people say that playing on anarchy servers far away from spawn is like singleplayer with chat, so this mod just makes
Carbyne Stack secret sharing distributed object store
Carbyne Stack Amphora Secret Share Store Amphora is an open source object store for secret shared data and part of Carbyne Stack. DISCLAIMER: Carbyne
A project provide a shell to talk to ratis server
ratis-shell A project provide a shell to talk to ratis server how to build mvn clean package how to run Prepare a config file cp ./conf/ratis-shell-si
This is a very lightweight plugin for Velocity proxy.
Essential-PlayerInfo Introduce This is a very lightweight plugin for Velocity proxy. Used API of Velocity 3.1.0, so it may only support Velocity versi
gMark: a domain- and query language-independent graph instance and query workload generator
gMark is a domain- and query language-independent graph instance and query workload generator.
Introduction to CYS4-SensitiveDiscoverer, a Burp extension that discovers sensitive information inside HTTP messages.
CYS4-SensitiveDiscoverer Introduction Burp Suite is a useful tool used to do web application security testing. While Burp Suite provides a lot of func
工信部APP个人隐私信息安全合规检测
由 ChenJunsen/Hegui3.0 项目 https://github.com/ChenJunsen/Hegui3.0 改版而来 增加了几个hook的点以及log打印的字符串，方便logcat中筛选 安装配置好此插件后adb shell logcat grep secheguicheck|g
An example Twitch.tv bot that allows you to manage channel rewards (without requiring a message), and chat messages.
Twitch Bot Example shit code that can be used as a template for a twitch bot that takes advantage of channel rewards (that dont require text input) an
ApnaKhata is a free staff attendance & payroll management app that can be used by owners and employees according to their perspectives
ApnaKhata is a free staff attendance & payroll management app that can be used by owners and employees according to their perspectives. It enables employers to easily manage their attendance, Working time hours, and salary Details. The owner can keep track of employees’ Working hours and salary Details
Carbyne Stack MP-SPDZ Integration Utilities
Carbyne Stack MP-SPDZ Integration Utilities This project provides utilities for using MP-SPDZ in the Carbyne Stack microservices. License Carbyne Stac
Output Keycloak Events and Admin Events to a Kafka topic.
keycloak-kafka-eventlistener Output Keycloak Events and Admin Events to a Kafka topic. Based on Keycloak 15.0.2+ / RH-SSO 7.5.0+ How to use the plugin
Template for an Apache Flink project.
Minimal Apache Flink Project Template It contains some basic jobs for testing if everything runs smoothly. How to Use This Repository Import this repo