kafka

PipelineAI

A modern Apache Kafka client for node.js

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

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...

A Microservice Toolkit from The New York Times

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

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.

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

The open source and enterprise-ready webhooks service 🦀

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

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

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

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

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

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

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

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

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

Open-Source Web UI for managing Apache Kafka clusters

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

Kafka exporter for Prometheus

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

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

Confluent Schema Registry for Kafka

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

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

Flow collector, enricher and visualizer

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

Ruby and Rails efficient Kafka processing framework

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

Node.js bindings for librdkafka

Production-ready, stable Kafka client for PHP

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

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

A lightweight stream processing library for Go

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

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

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

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

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)🔥🔥🔥🔥🔥

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

🦭 Distributed log streaming engine built from first principles

Python Stream Processing. A Faust fork

Secor is a service implementing Kafka log persistence

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