Trending repositories for topic kafka
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
工作流引擎对内提供单位/机关流程管理规则和内部业务流程的数字化落地实践；对外提供自动化地第三方业务驱动、接口接入和算法单元驱动能力。工作流引擎在提供底层驱动引擎的同时对全局透明监控、安全防御和国产化特色功能进行充分考虑，是内部流程管理和业务算法驱动的不二之选。
1000+ DevOps Bash Scripts - AWS, GCP, Kubernetes, Docker, CI/CD, APIs, SQL, PostgreSQL, MySQL, Hive, Impala, Kafka, Hadoop, Jenkins, GitHub, GitLab, BitBucket, Azure DevOps, TeamCity, Spotify, MP3, LD...
Best-in-class stream processing, analytics, and management. Perform continuous analytics, or build event-driven applications, real-time ETL pipelines, and feature stores in minutes. Unified streaming ...
数据流引擎是一款面向数据集成、数据同步、数据交换、数据共享、任务配置、任务调度的底层数据驱动引擎。数据流引擎采用管执分离、多流层、插件库等体系应对大规模数据任务、数据高频上报、数据高频采集、异构数据兼容的实际数据问题。
Open-source IoT Platform - Device management, data collection, processing and visualization.
Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.
Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024
Metering and Billing for AI, API and DevOps. Collect and aggregate millions of usage events in real-time and enable usage-based billing.
2023年最新整理 c++后端开发，1000篇优秀博文，含内存，网络，架构设计，高性能，数据结构，基础组件，中间件，分布式相关
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
数据流引擎是一款面向数据集成、数据同步、数据交换、数据共享、任务配置、任务调度的底层数据驱动引擎。数据流引擎采用管执分离、多流层、插件库等体系应对大规模数据任务、数据高频上报、数据高频采集、异构数据兼容的实际数据问题。
工作流引擎对内提供单位/机关流程管理规则和内部业务流程的数字化落地实践；对外提供自动化地第三方业务驱动、接口接入和算法单元驱动能力。工作流引擎在提供底层驱动引擎的同时对全局透明监控、安全防御和国产化特色功能进行充分考虑，是内部流程管理和业务算法驱动的不二之选。
100xDevs Cohort 3 🚀 by Harkirat Singh. This repository contains Lecture Codes, Notes, Assignments, Assignment Solution Code and Some Good Articles/Blogs Link. 🔥
Spring Boot 3 Microservices Course Repository
A drop-in replacement for Apache Kafka with PostgreSQL and S3 storage engines written in 100% safe 🦺 async 🚀 Rust 🦀
Moon是一款适用于多个领域的监控告警平台，支持云原生、物联网（IoT）和人工智能（AI）等多种应用场景。它不仅简化了云原生监控的运维工作，还具备强大的物联网和 AI 支持能力，能够满足不同行业和领域的多样化监控需求。通过实时数据监控、智能告警和故障响应，能够满足不同领域的监控需求。
Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.
k6 extension to load test Apache Kafka with support for various serialization formats, SASL, TLS, compression, Schema Registry client and beyond
⚡️ 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...
My Collection of Docker Compose Files. Use "make up" to test it.
Spring Boot microservices app with Spring Cloud, Robust and resilient backend managing e-Commerce app
Metering and Billing for AI, API and DevOps. Collect and aggregate millions of usage events in real-time and enable usage-based billing.
Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data
👍 👍 👍 高度仿制大麦网售票系统，使用 SpringCloudAlibaba、Kafka、Redis、Sentinel、ElasticSearch、ShardingSphere 等架构，实现 从抢票到生成订单完成支付 的整个流程，并包含各种高并发难题的实际落地解决方案。是面试、就业、提高技术的不二选择！
Apache Kafka .NET Framework to create applications simple to use and extend.
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
1000+ DevOps Bash Scripts - AWS, GCP, Kubernetes, Docker, CI/CD, APIs, SQL, PostgreSQL, MySQL, Hive, Impala, Kafka, Hadoop, Jenkins, GitHub, GitLab, BitBucket, Azure DevOps, TeamCity, Spotify, MP3, LD...
Open-source IoT Platform - Device management, data collection, processing and visualization.
工作流引擎对内提供单位/机关流程管理规则和内部业务流程的数字化落地实践；对外提供自动化地第三方业务驱动、接口接入和算法单元驱动能力。工作流引擎在提供底层驱动引擎的同时对全局透明监控、安全防御和国产化特色功能进行充分考虑，是内部流程管理和业务算法驱动的不二之选。
Best-in-class stream processing, analytics, and management. Perform continuous analytics, or build event-driven applications, real-time ETL pipelines, and feature stores in minutes. Unified streaming ...
数据流引擎是一款面向数据集成、数据同步、数据交换、数据共享、任务配置、任务调度的底层数据驱动引擎。数据流引擎采用管执分离、多流层、插件库等体系应对大规模数据任务、数据高频上报、数据高频采集、异构数据兼容的实际数据问题。
一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024
100xDevs Cohort 3 🚀 by Harkirat Singh. This repository contains Lecture Codes, Notes, Assignments, Assignment Solution Code and Some Good Articles/Blogs Link. 🔥
Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.
Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
2023年最新整理 c++后端开发，1000篇优秀博文，含内存，网络，架构设计，高性能，数据结构，基础组件，中间件，分布式相关
【大厂面试专栏】一份Java程序员需要的技术指南，这里有面试题、系统架构、职场锦囊、主流中间件等，让你成为更牛的自己！
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Event-Driven Architecture for a microservices-based system with a clean architecture + Domain Driven Design (DDD) + CQRS pattern + Saga pattern + Outbox pattern + CDC.
⚡️ 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...
工作流引擎对内提供单位/机关流程管理规则和内部业务流程的数字化落地实践；对外提供自动化地第三方业务驱动、接口接入和算法单元驱动能力。工作流引擎在提供底层驱动引擎的同时对全局透明监控、安全防御和国产化特色功能进行充分考虑，是内部流程管理和业务算法驱动的不二之选。
100xDevs Cohort 3 🚀 by Harkirat Singh. This repository contains Lecture Codes, Notes, Assignments, Assignment Solution Code and Some Good Articles/Blogs Link. 🔥
数据流引擎是一款面向数据集成、数据同步、数据交换、数据共享、任务配置、任务调度的底层数据驱动引擎。数据流引擎采用管执分离、多流层、插件库等体系应对大规模数据任务、数据高频上报、数据高频采集、异构数据兼容的实际数据问题。
Spring Boot 3 Microservices Course Repository
A drop-in replacement for Apache Kafka with PostgreSQL and S3 storage engines written in 100% safe 🦺 async 🚀 Rust 🦀
👍 👍 👍 高度仿制大麦网售票系统，使用 SpringCloudAlibaba、Kafka、Redis、Sentinel、ElasticSearch、ShardingSphere 等架构，实现 从抢票到生成订单完成支付 的整个流程，并包含各种高并发难题的实际落地解决方案。是面试、就业、提高技术的不二选择！
Spring Boot demo apps for testing Kafka transactions with other resources like database
Amplicode базируется на привычных для разработчиков средах разработки IntelliJ IDEA и VS Code и предоставляет инструменты максимально комфортной и эффективной разработки сервисов и web-приложений на S...
RobustMQ is a next-generation, high-performance, cloud-native, converged message queue that is compatible with multiple mainstream message queuing protocols and has complete Serveless capabilities.
Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.
My Collection of Docker Compose Files. Use "make up" to test it.
Typescript API that implements CQRS & Event Sourcing
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...
An interactive terminal user interface (TUI) application for exploring data of a kafka cluster.
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
1000+ DevOps Bash Scripts - AWS, GCP, Kubernetes, Docker, CI/CD, APIs, SQL, PostgreSQL, MySQL, Hive, Impala, Kafka, Hadoop, Jenkins, GitHub, GitLab, BitBucket, Azure DevOps, TeamCity, Spotify, MP3, LD...
Open-source IoT Platform - Device management, data collection, processing and visualization.
工作流引擎对内提供单位/机关流程管理规则和内部业务流程的数字化落地实践；对外提供自动化地第三方业务驱动、接口接入和算法单元驱动能力。工作流引擎在提供底层驱动引擎的同时对全局透明监控、安全防御和国产化特色功能进行充分考虑，是内部流程管理和业务算法驱动的不二之选。
C++ Parallel Computing and Asynchronous Networking Framework
数据流引擎是一款面向数据集成、数据同步、数据交换、数据共享、任务配置、任务调度的底层数据驱动引擎。数据流引擎采用管执分离、多流层、插件库等体系应对大规模数据任务、数据高频上报、数据高频采集、异构数据兼容的实际数据问题。
Best-in-class stream processing, analytics, and management. Perform continuous analytics, or build event-driven applications, real-time ETL pipelines, and feature stores in minutes. Unified streaming ...
AutoMQ is a cloud-first alternative to Kafka by decoupling durability to S3 and EBS. 10x Cost-Effective. No Cross-AZ Traffic Cost. Autoscale in seconds. Single-digit ms latency.
Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.
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.
2023年最新整理 c++后端开发，1000篇优秀博文，含内存，网络，架构设计，高性能，数据结构，基础组件，中间件，分布式相关
100xDevs Cohort 3 🚀 by Harkirat Singh. This repository contains Lecture Codes, Notes, Assignments, Assignment Solution Code and Some Good Articles/Blogs Link. 🔥
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
Open Source Customer Engagement Platform (Customer.io Alternative)
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
工作流引擎对内提供单位/机关流程管理规则和内部业务流程的数字化落地实践；对外提供自动化地第三方业务驱动、接口接入和算法单元驱动能力。工作流引擎在提供底层驱动引擎的同时对全局透明监控、安全防御和国产化特色功能进行充分考虑，是内部流程管理和业务算法驱动的不二之选。
数据流引擎是一款面向数据集成、数据同步、数据交换、数据共享、任务配置、任务调度的底层数据驱动引擎。数据流引擎采用管执分离、多流层、插件库等体系应对大规模数据任务、数据高频上报、数据高频采集、异构数据兼容的实际数据问题。
Event-Driven Architecture for a microservices-based system with a clean architecture + Domain Driven Design (DDD) + CQRS pattern + Saga pattern + Outbox pattern + CDC.
100xDevs Cohort 3 🚀 by Harkirat Singh. This repository contains Lecture Codes, Notes, Assignments, Assignment Solution Code and Some Good Articles/Blogs Link. 🔥
The goal of this project is to implement a "News" processing pipeline composed of five Spring Boot applications: producer-api, categorizer-service, collector-service, publisher-api and news-client.
My Collection of Docker Compose Files. Use "make up" to test it.
Spring Boot 3 Microservices Course Repository
A drop-in replacement for Apache Kafka with PostgreSQL and S3 storage engines written in 100% safe 🦺 async 🚀 Rust 🦀
👍 👍 👍 高度仿制大麦网售票系统，使用 SpringCloudAlibaba、Kafka、Redis、Sentinel、ElasticSearch、ShardingSphere 等架构，实现 从抢票到生成订单完成支付 的整个流程，并包含各种高并发难题的实际落地解决方案。是面试、就业、提高技术的不二选择！
⚡️ 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...
Data Engineering Project with Hadoop HDFS and Kafka
RobustMQ is a next-generation, high-performance, cloud-native, converged message queue that is compatible with multiple mainstream message queuing protocols and has complete Serveless capabilities.
Trench — Open-Source Analytics Infrastructure. A single production-ready Docker image built on ClickHouse, Kafka, and Node.js for tracking events, page views. Easily build product analytics dashboards...
Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.
工作流引擎对内提供单位/机关流程管理规则和内部业务流程的数字化落地实践；对外提供自动化地第三方业务驱动、接口接入和算法单元驱动能力。工作流引擎在提供底层驱动引擎的同时对全局透明监控、安全防御和国产化特色功能进行充分考虑，是内部流程管理和业务算法驱动的不二之选。
🍃spring-rs is a application framework written in rust inspired by java's spring-boot
数据流引擎是一款面向数据集成、数据同步、数据交换、数据共享、任务配置、任务调度的底层数据驱动引擎。数据流引擎采用管执分离、多流层、插件库等体系应对大规模数据任务、数据高频上报、数据高频采集、异构数据兼容的实际数据问题。
100xDevs Cohort 3 🚀 by Harkirat Singh. This repository contains Lecture Codes, Notes, Assignments, Assignment Solution Code and Some Good Articles/Blogs Link. 🔥
👍 👍 👍 高度仿制大麦网售票系统，使用 SpringCloudAlibaba、Kafka、Redis、Sentinel、ElasticSearch、ShardingSphere 等架构，实现 从抢票到生成订单完成支付 的整个流程，并包含各种高并发难题的实际落地解决方案。是面试、就业、提高技术的不二选择！
A drop-in replacement for Apache Kafka with PostgreSQL and S3 storage engines written in 100% safe 🦺 async 🚀 Rust 🦀
A tech stack agnostic Event Driven Workflow framework, written in Go, that supports durable, robust, and idempotent state changes with timeouts, callbacks, scheduled triggers, and await calls. Compati...
Bu repoda aslında asenkron mesaj kuyruklarını hedef alan bir dağıtık sistem problemi oluşturmaya ve bu problemin çözümünü uygulamaya çalışıyorum.
Spring template for a REST service designed with Hexagonal architecture
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.
1000+ DevOps Bash Scripts - AWS, GCP, Kubernetes, Docker, CI/CD, APIs, SQL, PostgreSQL, MySQL, Hive, Impala, Kafka, Hadoop, Jenkins, GitHub, GitLab, BitBucket, Azure DevOps, TeamCity, Spotify, MP3, LD...
AutoMQ is a cloud-first alternative to Kafka by decoupling durability to S3 and EBS. 10x Cost-Effective. No Cross-AZ Traffic Cost. Autoscale in seconds. Single-digit ms latency.
Open-source IoT Platform - Device management, data collection, processing and visualization.
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.
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Best-in-class stream processing, analytics, and management. Perform continuous analytics, or build event-driven applications, real-time ETL pipelines, and feature stores in minutes. Unified streaming ...
Agent for collecting, processing, aggregating, and writing metrics, logs, and other arbitrary data.
Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.
C++ Parallel Computing and Asynchronous Networking Framework
Trench — Open-Source Analytics Infrastructure. A single production-ready Docker image built on ClickHouse, Kafka, and Node.js for tracking events, page views. Easily build product analytics dashboards...
一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024
2023年最新整理 c++后端开发，1000篇优秀博文，含内存，网络，架构设计，高性能，数据结构，基础组件，中间件，分布式相关
RobustMQ is a next-generation, high-performance, cloud-native, converged message queue that is compatible with multiple mainstream message queuing protocols and has complete Serveless capabilities.
Stream supports lightweight messaging within Spring-based applications and supports integration with external systems through declarative adapters
Self-contained distributed software platform for building stateful, massively real-time streaming applications in Rust.
AutoMQ is a cloud-first alternative to Kafka by decoupling durability to S3 and EBS. 10x Cost-Effective. No Cross-AZ Traffic Cost. Autoscale in seconds. Single-digit ms latency.
Moon是一款适用于多个领域的监控告警平台，支持云原生、物联网（IoT）和人工智能（AI）等多种应用场景。它不仅简化了云原生监控的运维工作，还具备强大的物联网和 AI 支持能力，能够满足不同行业和领域的多样化监控需求。通过实时数据监控、智能告警和故障响应，能够满足不同领域的监控需求。
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
kaskade is a text user interface for kafka, which allows you to interact and consume topics from your terminal in style!
Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.
A Django library for asynchronously triggering actions in response to database changes. It supports integration with webhooks, message brokers (e.g., Kafka, RabbitMQ), and can trigger other processes,...
Spring Boot Microservices project (Gateway, Config Server, Kafka)
반려식물 및 식물 용품을 중고거래를 하고, 반려식물을 관리하기 위한 정보를 얻을수 있으며 내가 키우는 반려식물을 sns 형식으로 공유하는 플랫폼, 식구하자
⚡️ 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...
This project shows how to capture changes from postgres database and stream them into kafka
2023年最新整理 c++后端开发，1000篇优秀博文，含内存，网络，架构设计，高性能，数据结构，基础组件，中间件，分布式相关
Data Engineering Project with Hadoop HDFS and Kafka
Full-stack Highly Scalable Cloud-native Machine Learning system for demand forecasting with realtime data streaming, inference, retraining loop, and more
An efficient and scalable library for stateless Kafka message processing written in Go