Trending repositories for topic kafka
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Open-source IoT Platform - Device management, data collection, processing and visualization.
More than 2000+ Data engineer interview questions.
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
SQL stream processing, analytics, and management. We decouple storage and compute to offer instant failover, dynamic scaling, speedy bootstrapping, and efficient joins.
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024
2023年最新整理 c++后端开发，1000篇优秀博文，含内存，网络，架构设计，高性能，数据结构，基础组件，中间件，分布式相关
Full-stack Highly Scalable Cloud-native Machine Learning system for demand forecasting with realtime data streaming, inference, retraining loop, and more
More than 2000+ Data engineer interview questions.
强烈推荐🔥🔥🔥 🦜麻雀虽小五脏俱全🦜 🏄🏻♂️ 享受环境一切顺利的快乐🏄🏻♂️ 🌍所有环境统一规范管理🌍📦超强环境打包管理器📦🔨 一键快速启动多个服务环境的容器化编排工具 🔨 / A Docker tool for one-click startup of multiple services.
⚡️ Microservice Architecture with system for e-commerce project! Spring Boot microservices app with 🌀 Spring Cloud, Robust and resilient backend managing e-Commerce app... ❄️ Using Kafka Client, kaf...
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
2023年最新整理 c++后端开发，1000篇优秀博文，含内存，网络，架构设计，高性能，数据结构，基础组件，中间件，分布式相关
Replicate data from MySQL, Postgres and MongoDB to ClickHouse
A modern and practical kafka GUI client | 一个现代、实用的kafka界面客户端。
taotao-cloud (taotao云平台) 基于gradle8.7、jdk21, 支持graalvm21, 采用最新的spring 6.1.8、SpringBoot 3.3.0、SpringCloud 2023.0.2、SpringSecurity 6.2.4、Nacos 2.3.2、Mybatis-Plus 3.5.6等框架开发的微服务开发脚手架,包括大数据模块、微服务模块、前端模块。基于...
KLoadGen is kafka load generator plugin for jmeter designed to work with AVRO, JSON and PROTOL-BUFFERS schema Registries.
🐳✨ Fully automated Apache Kafka® and Confluent Docker based examples // 👷♂️ Easily build examples or reproduction models
KCloud-Platform-IoT（阻塞式）（老寇IoT云平台）是一个企业级微服务架构的IoT云平台。采用DDD(领域驱动设计)思想，基于Spring Boot 3.3.0、Spring Cloud 2023.0.2、Spring Cloud Alibaba 2023.0.1.0 最新版本开发的云服务多租户IoT平台，家人们，点个star！拜托啦~
This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Open-source IoT Platform - Device management, data collection, processing and visualization.
Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
More than 2000+ Data engineer interview questions.
AutoMQ is a cloud-native fork of Kafka by separating storage to S3 and EBS. 10x cost-effective. Autoscale in seconds. Single-digit ms latency.
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
A modern and practical kafka GUI client | 一个现代、实用的kafka界面客户端。
⚡️ Microservice Architecture with system for e-commerce project! Spring Boot microservices app with 🌀 Spring Cloud, Robust and resilient backend managing e-Commerce app... ❄️ Using Kafka Client, kaf...
kaskade is a kafka text user interface that allows you to interact with kafka and consume topics from your terminal in style!
More than 2000+ Data engineer interview questions.
2023年最新整理 c++后端开发，1000篇优秀博文，含内存，网络，架构设计，高性能，数据结构，基础组件，中间件，分布式相关
Full-stack Highly Scalable Cloud-native Machine Learning system for demand forecasting with realtime data streaming, inference, retraining loop, and more
Klaw, the latest OS tool by Aiven, helps enterprises cope with Apache Kafka(r) topics, schema registry and connectors governance by introducing roles/authorizations to users of various teams of an org...
Utility to help with draining nodes running Strimzi-managed Apache Kafka® or ZooKeeper® pods
强烈推荐🔥🔥🔥 🦜麻雀虽小五脏俱全🦜 🏄🏻♂️ 享受环境一切顺利的快乐🏄🏻♂️ 🌍所有环境统一规范管理🌍📦超强环境打包管理器📦🔨 一键快速启动多个服务环境的容器化编排工具 🔨 / A Docker tool for one-click startup of multiple services.
AutoMQ is a cloud-native fork of Kafka by separating storage to S3 and EBS. 10x cost-effective. Autoscale in seconds. Single-digit ms latency.
KCloud-Platform-IoT（阻塞式）（老寇IoT云平台）是一个企业级微服务架构的IoT云平台。采用DDD(领域驱动设计)思想，基于Spring Boot 3.3.0、Spring Cloud 2023.0.2、Spring Cloud Alibaba 2023.0.1.0 最新版本开发的云服务多租户IoT平台，家人们，点个star！拜托啦~
上百本大数据电子书，附带下载链接，包括计算机基础，Java，hadoop，spark，flink，kafka，hbase，hive，数仓等
Comprehensible material for those who want to learn about Apache Kafka architecture.
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Open-source IoT Platform - Device management, data collection, processing and visualization.
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
AutoMQ is a cloud-native fork of Kafka by separating storage to S3 and EBS. 10x cost-effective. Autoscale in seconds. Single-digit ms latency.
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024
Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
More than 2000+ Data engineer interview questions.
Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
SQL stream processing, analytics, and management. We decouple storage and compute to offer instant failover, dynamic scaling, speedy bootstrapping, and efficient joins.
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
End to end data engineering project with kafka, airflow, spark, postgres and docker.
A modern and practical kafka GUI client | 一个现代、实用的kafka界面客户端。
AutoMQ is a cloud-native fork of Kafka by separating storage to S3 and EBS. 10x cost-effective. Autoscale in seconds. Single-digit ms latency.
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
Utility to help with draining nodes running Strimzi-managed Apache Kafka® or ZooKeeper® pods
More than 2000+ Data engineer interview questions.
⚡️ Microservice Architecture with system for e-commerce project! Spring Boot microservices app with 🌀 Spring Cloud, Robust and resilient backend managing e-Commerce app... ❄️ Using Kafka Client, kaf...
强烈推荐🔥🔥🔥 🦜麻雀虽小五脏俱全🦜 🏄🏻♂️ 享受环境一切顺利的快乐🏄🏻♂️ 🌍所有环境统一规范管理🌍📦超强环境打包管理器📦🔨 一键快速启动多个服务环境的容器化编排工具 🔨 / A Docker tool for one-click startup of multiple services.
Demo saga pattern, outbox pattern using Spring Boot, Debezium, Kafka, Kafka Connect
2023年最新整理 c++后端开发，1000篇优秀博文，含内存，网络，架构设计，高性能，数据结构，基础组件，中间件，分布式相关
Full-stack Highly Scalable Cloud-native Machine Learning system for demand forecasting with realtime data streaming, inference, retraining loop, and more
AutoMQ is a cloud-native fork of Kafka by separating storage to S3 and EBS. 10x cost-effective. Autoscale in seconds. Single-digit ms latency.
Cloud Metering for AI, Billing and FinOps. Collect and aggregate millions of usage events in real-time.
:books: Tech blogs & talks by companies that run Kafka in production
LangStream. Event-Driven Developer Platform for Building and Running LLM AI Apps. Powered by Kubernetes and Kafka.
Get data from API, run a scheduled script with Airflow, send data to Kafka and consume with Spark, then write to Cassandra
This project allows developers to build services for exporting REST APIs. It makes it easy to connect to databases, cache, Kafka, S3, elasticsearch and authentication. Keep building !
强烈推荐🔥🔥🔥 🦜麻雀虽小五脏俱全🦜 🏄🏻♂️ 享受环境一切顺利的快乐🏄🏻♂️ 🌍所有环境统一规范管理🌍📦超强环境打包管理器📦🔨 一键快速启动多个服务环境的容器化编排工具 🔨 / A Docker tool for one-click startup of multiple services.
Integration that uses Home Assistant Kafka integration for creating home automations in .NET and C#
Open Source streaming platform. Write and run typed data pipelines with a minimal, familiar syntax.
⚡️ Microservice Architecture with system for e-commerce project! Spring Boot microservices app with 🌀 Spring Cloud, Robust and resilient backend managing e-Commerce app... ❄️ Using Kafka Client, kaf...
Template to quickstart streaming analytics using Apache Kafka for ingestion, QuestDB for time-series storage and analytics, Grafana for near real-time dashboards, and Jupyter Notebook for data science
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Open-source IoT Platform - Device management, data collection, processing and visualization.
SQL stream processing, analytics, and management. We decouple storage and compute to offer instant failover, dynamic scaling, speedy bootstrapping, and efficient joins.
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
C++ Parallel Computing and Asynchronous Networking Framework
KubeBlocks is an open-source control plane that runs and manages databases, message queues and other data infrastructure on K8s.
一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024
The API traffic analyzer for Kubernetes providing real-time K8s protocol-level visibility, capturing and monitoring all traffic and payloads going in, out and across containers, pods, nodes and cluste...
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
AutoMQ is a cloud-native fork of Kafka by separating storage to S3 and EBS. 10x cost-effective. Autoscale in seconds. Single-digit ms latency.
Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
AutoMQ is a cloud-native fork of Kafka by separating storage to S3 and EBS. 10x cost-effective. Autoscale in seconds. Single-digit ms latency.
:books: Tech blogs & talks by companies that run Kafka in production
Cloud Metering for AI, Billing and FinOps. Collect and aggregate millions of usage events in real-time.
🎨 UI for the Free Data Engineering Zoomcamp Course provided by DataTalksClub
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
KubeBlocks is an open-source control plane that runs and manages databases, message queues and other data infrastructure on K8s.
Streaming processing framework, source, channel, sink, support mqtt, Kafka and other components
Kstreamplify is a Java library that brings new features on top of Kafka Streams.
Modern Reactive CQRS Architecture Microservice development framework based on DDD and EventSourcing | 基于 DDD & EventSourcing 的现代响应式 CQRS 架构微服务开发框架
An AsyncAPI Golang Code generator that generates all Go code from the broker to the application/user. Just plug your application to your favorite message broker!
Open Source streaming platform. Write and run typed data pipelines with a minimal, familiar syntax.
RemoteStorageManager for Apache Kafka® Tiered Storage
Create a streaming data, transfer it to Kafka, modify it with PySpark, take it to ElasticSearch and MinIO
Shortlink service (Microservice example) ⭐️ Star the repo if you like it!
Database replication platform that leverages change data capture. Stream production data from databases to your data warehouse (Snowflake, BigQuery, Redshift) in real-time.
2023年最新整理 c++后端开发，1000篇优秀博文，含内存，网络，架构设计，高性能，数据结构，基础组件，中间件，分布式相关