kafka

Communication infrastructure for the AI era — one binary, one broker, one storage layer, any protocol

大数据知识仓库涉及到数据仓库建模、实时计算、大数据、数据中台、系统设计、Java、算法等。

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

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

More than 2000+ Data engineer interview questions.

🦎 A lightweight, multi-protocol gateway for event-driven applications and AI agents. Expose and govern Kafka, MQTT, APIs, and MCP through one high-pe...

Vanus is a Serverless, event streaming system with processing capabilities. It easily connects SaaS, Cloud Services, and Databases to help users buil...

Event Sourcing for Go!

Trench — Open-Source Analytics Infrastructure. A single production-ready Docker image built on ClickHouse, Kafka, and Node.js for tracking events. Eas...

:dart: :star2:[大数据面试题]分享自己在网络上收集的大数据相关的面试题以及自己的答案总结.目前包含Hadoop/Hive/Spark/Flink/Hbase/Kafka/Zookeeper框架的面试...

Python Streaming DataFrames for Kafka

Scripts and samples to support Confluent Demos, Talks, and Blogs. Not all of the examples in this repository are kept up to date. For automated tutori...

100xDevs Cohort 3 🚀 by Harkirat Singh. This repository contains Lecture Codes, Notes, Assignments, Assignment Solution Code and Some Good Articles/Bl...

Test your code without writing mocks with ephemeral Docker containers 📦 Setup popular services with just a couple lines of code ⏱️ No bash, no yaml,...

Machine Learning Platform and Recommendation Engine built on Kubernetes

Reliable messages resolve distributed transactions

OLake - Fastest Databases, Kafka & S3 Replication to Apache Iceberg with Table optimization (Called OLake Fusion). ⚡ Efficient, quick and scalable da...

Distributed Prometheus time series database

Rust client for Apache Kafka

Example end to end data engineering project.

kafka php client

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

asyncio client for kafka

High performance mqtt broker

Wait4X allows you to wait for a port or a service to enter the requested state.

50+ DockerHub public images for Docker & Kubernetes - DevOps, CI/CD, GitHub Actions, CircleCI, Jenkins, TeamCity, Alpine, CentOS, Debian, Fedora, Ubun...

:fireworks: Flexible and extendable containerized workspaces. Now. with free offline chat GPT!!! 🚀🚀🚀

A modern and practical kafka GUI client 💕🎉Kafka-King 是一款现代化、实用的 Kafka GUI 客户端，旨在通过直观的桌面界面简化 Apache Kafka 管理。作为一款跨...

High performance Rust stream processing engine seamlessly integrates AI capabilities, providing powerful real-time data processing and intelligent ana...

java-study 是本人学习Java过程中记录的一些代码！从Java基础的数据类型、jdk1.8的Lambda、Stream和日期的使用、 IO流、数据集合、多线程使用、并发编程、23种设...

A Ruby client library for Apache Kafka

A web clone of the card game Cards Against Humanity.

pmacct is a small set of multi-purpose passive network monitoring tools [NetFlow IPFIX sFlow libpcap BGP BMP RPKI IGP Streaming Telemetry].

go-stash is a high performance, free and open source server-side data processing pipeline that ingests data from Kafka, processes it, and then sends i...

This Scrapy project uses Redis and Kafka to create a distributed on demand scraping cluster.

Kubernetes Universal Declarative Operator (KUDO)

imi 是一款支持长连接微服务分布式的 PHP 开发框架，它可以运行在 PHP-FPM、Swoole、Workerman、RoadRunner 等多种容器环境下。它支持 HttpApi、WebSocket、TCP...

KCenter(KafkaCenter) is a unified platform for kafka cluster management and maintenance, producer / consumer monitoring, and use of ecological compon...

docker-compose.yml files for cp-all-in-one , cp-all-in-one-community, cp-all-in-one-cloud, Apache Kafka Confluent Platform

Enterprise Network Flow Collector (IPFIX, sFlow, Netflow)

450+ AWS, Hadoop, Cloud, Kafka, Docker, Elasticsearch, RabbitMQ, Redis, HBase, Solr, Cassandra, ZooKeeper, HDFS, Yarn, Hive, Presto, Drill, Impala, Co...

后端面试题汇总（Python、Redis、MySQL、PostgreSQL、Kafka、数据结构、算法、编程、网络）

Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.

Distributed Stream and Batch Processing

使用 golang 模仿的 Logstash。用于消费 Kafka 数据，处理后写入 ES、Clickhouse 等。

🔥 🔥 官方推荐 🔥 🔥 高并发大麦网售票系统，使用 SpringCloud、Kafka、Redis、Sentinel、ElasticSearch、ShardingSphere 等，通过优化锁的策略、多级缓存管理...

Command Line Tool for managing Apache Kafka

A collection of Kafka Connect sinks and sources maintained by Lenses.io.

[DEPRECATED] Docker images for Confluent Platform.

The Apache Kafka C/C++ library