A Kafka audit system

Chaperone (This project is deprecated and not maintained.) As Kafka audit system, Chaperone monitors the completeness and latency of data stream. The audit metrics are persisted in database for Kafka users to quantify the loss o
Category: Java / Messaging
Watchers: 1.9k
Star: 635
Fork: 150
Last update: May 2, 2022

Related Repos


akka Alpakka Kafka Connector Systems don't come alone. In the modern world of microservices and cloud deployment, new components must interact with legacy

OpenHFT Chronicle Queue Table of Contents About Chronicle Software Overview What Is Chronicle Queue? Design Motivation and Features Usage Downloading Chronicl

marianobarrios TLS Channel TLS Channel is a library that implements a ByteChannel interface over a TLS (Transport Layer Security) connection. It delegates all crypto

apache RocketMQ CloudEvents Slogan:TBD Features TBD How to use Step-by-step instruction are provided in RocketMQ Cloudevents Introduction Consult RocketMQ Qu

rabbitmq This repository contains source code of the RabbitMQ Java client

mrpkdeveloper 450-DSA-Questions 🔥 🔥 Hello world 👋 👋 , This repo contains the JAVA solutions for DSA Cheat Sheet provide by Love Babbar bhaiya. These questions a

dromara Reliable messages resolve distributed transactions

confluentinc kafka-connect-jdbc is a Kafka Connector for loading data to and from any JDBC-compatible database.

streamthoughts Azkarra Streams is a lightweight Java framework which makes easy to develop and operate Kafka Streams applications (Azkarra is Basque words for "Fast") Kafka Streams is a client library for building applications and microservices, whe

apache RocketMQ-Spring This project aims to help developers quickly integrate RocketMQ with Spring Boot. Features Send messages synchronously Send messages asynchronously Send messages in one-way mode Se

apache 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://pulsar.apache.org Main features Horizontally scalable (Millions of ind

google Capillary This is a library to simplify the sending of end-to-end (E2E) encrypted push messages from Java-based application servers to Android clients. Please check the instructions below and the demo for more details.

apache Apache RocketMQ Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level capacity and flexible scalability. It offers a variety of features:

qingmang-team ChanaMQ Server ChanaMQ is an Akka based, AMQP messaging broker. It currently supports: AMQP 0-9-1 Status ChanaMQ is still in the alpha phase. Methods/Features are not supported yet: Authentication /

openmessaging A vendor-neutral open standard for distributed messaging and streaming OpenMessaging, which includes the establishment of industry guidelines and messaging, streaming specifications to provide a common framework