kafka

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

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

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

More than 2000+ Data engineer interview questions.

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!

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

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

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

Distributed Prometheus time series database

Rust client for Apache Kafka

kafka php client

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

Example end to end data engineering project.

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

asyncio client for kafka

High performance mqtt broker

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

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

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

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

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

A Ruby client library for Apache Kafka

A modern and practical kafka GUI client 💕🎉Kafka-King 是一款现代化、实用的 Kafka GUI 客户端，旨在通过直观的桌面界面简化 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].

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

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

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

Enterprise Network Flow Collector (IPFIX, sFlow, Netflow)

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

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

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

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

Distributed Stream and Batch Processing

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

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

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

[DEPRECATED] Docker images for Confluent Platform.

Command Line Tool for managing Apache Kafka

spring cloud 版分布式电商项目，全力打造顶级多模块，高可用，高扩展电商项目

🎉🎉🎉JAVA高级架构师技术栈==任何技能通过 “刻意练习” 都可以达到融会贯通的境界，就像烹饪一样，这里有一份JAVA开发技术手册，只需要增加自己练习的次数。🏃🏃...

SiteWhere is an industrial strength open-source application enablement platform for the Internet of Things (IoT). It provides a multi-tenant microserv...