kafka

High-performance open-source in-memory graph database for GraphRAG, AI memory, agentic AI, and real-time graph analytics. Cypher-compatible, built in...

Kafka GUI for Apache Kafka to manage topics, topics data, consumers group, schema registry, connect and more...

A Microservice Toolkit from The New York Times

Real-time transport layer for Java AI agents. Build once with @Agent — deliver over WebSocket, SSE, gRPC, and WebTransport/HTTP3. Talk MCP, A2A and AG...

docker compose files to create a fully working kafka stack

Alink is the Machine Learning algorithm platform based on Flink, developed by the PAI team of Alibaba computing platform.

Usage-based pricing and billing for developers 🔓 Cloud or self-hosted ⚙️ No-code UI 💰 Realtime usage metering 🎟 Credits & top-ups 🔑 Control feature...

2021面试题，Java面试题、JVM面试题、多线程面试题、并发编程、设计模式面试题、SpringBoot面试题、SpringCloud面试题、MyBatis面试题、ZooKeepe面试题r、Dubbo...

Surging is a micro-service engine that provides a lightweight, high-performance, modular RPC request pipeline. support Event-based Asynchronous Patte...

A AI-Driven, Distributed and high-performance monitoring system, for comprehensive monitoring and management of kafka cluster.

大数据学习，从零开始学习大数据，包含大数据学习各阶段学习视频、面试资料

The open source and enterprise-ready webhooks service 🦀

Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage

Cruise-control is the first of its kind to fully automate the dynamic workload rebalance and self-healing of a Kafka cluster. It provides great value...

An immutable SQL database for application development, time-travel reporting and data compliance. Developed by @juxt

:egg: Netty实践学习案例，见微知著！带着你的心，跟着教程。我相信你行欧。

QMQ是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景； 也包括报价搜索等高吞吐量场...

franz-go is a feature complete, pure Go library for Kafka from 0.8.0 through 4.2+. Producing, consuming, transacting, administrating, etc.

「Java面试小抄」一份通向理想互联网公司的面试汇总，包括 Java基础、Java并发、JVM、MySQL、Redis、Spring、MyBatis、Kafka、计算机操作系统、计算机网络、系统...

Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.

Kafka exporter for Prometheus

深圳地铁大数据客流分析系统🚇🚄🌟

Full-stack .Net 10 Clean Architecture (Microservices, Modular Monolith, Monolith), Blazor, Angular 21, React 19, Vue 3.5, BFF with YARP, NextJs 16, Do...

Confluent Schema Registry for Kafka

A framework for building messaging apps with .NET and C#.

syslog-ng is an enhanced log daemon, supporting a wide range of input and output methods: syslog, unstructured text, queueing, SQL & NoSQL.

High-performance log ingestion and ETL engine

Ruby and Rails efficient Kafka processing framework

Open-Source Web UI for managing Apache Kafka clusters

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

Node.js bindings for librdkafka

Flow collector, enricher and visualizer

Production-ready, stable Kafka client for PHP

2023年最新整理 c++后端开发，1000篇优秀博文，含内存，网络，架构设计，高性能，数据结构，基础组件，中间件，分布式相关

A lightweight stream processing library for Go

A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems.

✍️ Java 工程师必备架构体系知识总结：涵盖分布式、微服务、RPC等互联网公司常用架构，以及数据存储、缓存、搜索等必备技能

Kafka Docker for development. Kafka, Zookeeper, Schema Registry, Kafka-Connect, , 20+ connectors

Postgres change data capture to streams, queues, and search indexes like Kafka, SQS, Elasticsearch, HTTP endpoints, and more

Apache Kafka, Apache Flink and Confluent Platform examples and demos

A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka

Java生态研究(Spring Boot + Redis + Dubbo + RocketMQ + Elasticsearch)🔥🔥🔥🔥🔥

Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.

This repo contains my notes on working with Go and computer systems.

Metering and Billing for AI, API and DevOps. Collect and aggregate millions of usage events in real-time and enable usage-based billing.

🦭 Distributed log streaming engine built from first principles

Python Stream Processing. A Faust fork

Secor is a service implementing Kafka log persistence

前端性能监控系统,消息队列,高可用,集群等相关架构

Oryx 2: Lambda architecture on Apache Spark, Apache Kafka for real-time large scale machine learning