Kafka Web UI

Xinfra Monitor monitors the availability of Kafka clusters by producing synthetic workloads using end-to-end pipelines to obtain derived vital statistics - E2E latency, service produce/consume availability, offsets commit availability & latency, message loss rate and more.

MQTTX Project 完整实现 mqttv3.1.1 协议，旨在提供易于使用且性能优异的 mqtt broker

Open Source Package for Gibbs Sampling of LDA

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

Hands-on workshop for websphere MQ programming

The most simple way to test Kafka based applications or micro-services e.g. Read/Write during HBase/Hadoop or other Data Ingestion Pipe Lines

JMeter plugin to execute load test over Kinesis Data Stream, SQS Standard and FIFO Queues, SNS Standard and FIFO Topics, Cognito AWS services.

A ROS system running completely on Java. No ROS installation required. The system includes a Java roscore, a Topic Publisher, a Topic Subscriber, a Service Server and a Service Client.

NiFi processor emulating queue/topic patterns on top of Redis

Using firebase admin sdk ✌

Apache Kafka Java Library. Abstraction of Apache Kafka pub/sub messaging template. Support many serialization data formats.

Calyx Android App GitHub repository

A Kafka connector for subscribing to topics and streaming messages into MarkLogic

The Amazon SNS Java Messaging Library holds the compatible classes, that are used for communicating with Amazon Simple Notification Service. This project builds on top of the AWS SDK for Java to use Amazon SNS provider for the messaging applications without running any additional software.

Understand how your KSQL queries and KStreams-Applications depend on shared topics in a Kafka cluster.

Extension that allows to receive and publish events from/to rabbitmq broker.

Client-server high level abstraction library.

Reservoir Sampling for Group-By Queries in Flink Platform. Answering effectively Single Aggregate.