kafka

WeDataSphere is a financial grade, one-stop big data platform suite.

Zenko is the open source multi-cloud data controller: own and keep control of your data on any cloud.

KCloud-Platform-IoT（老寇IoT云平台）是一个企业级单体架构和微服务架构的IoT云平台。采用DDD(领域驱动设计)思想，基于Spring Boot 4.1.0、Spring Cloud 2025.1...

Monitor Kafka Consumer Group Latency with Kafka Lag Exporter

Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.

NetDiscovery 是一款基于 Vert.x、RxJava 2 等框架实现的通用爬虫框架/中间件。

In this repository, I have developed the entire server-side principal architecture for real-time stock market prediction with Machine Learning. I have...

Modern C++ Apache Kafka client library (wrapper for librdkafka)

Datafaker is a large-scale test data and flow test data generation tool. Datafaker fakes data and inserts to varied data sources. 测试数据生成工具

🔥🔥🔥可视化拖拽式大数据集成平台、大数据平台、大数据，包含数据流、数据源、数据对齐、查询模板、智能问数、AI集成、完善的监控等。像画流程图一样且无代码方...

Proxy connections to Kafka cluster. Connect through SOCKS Proxy, HTTP Proxy or to cluster running in Kubernetes.

DoctorK is a service for Kafka cluster auto healing and workload balancing

Karapace - Your Apache Kafka® essentials in one tool

Terraform provider for managing Apache Kafka Topics + ACLs

基于 scrapy-redis 的通用分布式爬虫框架

A cohesive & pragmatic framework of FP centric Scala libraries

Kafka client library for Elixir

Venice, Derived Data Platform for Planet-Scale Workloads.

Comprehensive guide to a couple of possible ways of synchronizing two states with Spring tools. Synchronization is shown by separating command and que...

Conduit streams data between data stores. Kafka Connect replacement. No JVM required.

Create low-latency, interactive user experiences for stateless microservices.

Community driven, reusable components for distributed apps

🚀 超级八股文 🚀 - 告别死记硬背的 Java 全栈技术知识库！100万+字的讲解，原理剖析 + 丰富代码示例 + 清晰流程图解，让你真正理解每一个技术点！

A curated list of Apache Kafka learning resources

A list about Apache Kafka

Sample Event Sourcing implementation with .NET Core

Kafka-based Job Queue for Python

SpringBoot框架源码实战（已更新到springboot2版本实现）~基本用法，Rest，Controller，事件监听，连接数据库MySQL，jpa，redis集成，mybatis集成（声明式与xml...

Based on the proxy gateway service of dubbo-go, it solves the problem that the external protocol calls the internal Dubbo cluster. At present, it supp...

Instagram Clone - Cloning Instagram for learning purpose

dnc 去中心化 开源社区 轻联盟 dncto.com QQ群 779699538

.NET Stream Processing Library for Apache Kafka 🚀

Easily load data from kafka to ClickHouse

Real Time Analytics and Data Pipelines based on Spark Streaming

电商大数据商品实时推荐系统，Vue + TypeScript + ElementUI+ Spring + Spark

An open source distributed tracing & observability platform

Deprecated - See Lenses.io Community Edition

Racecar: a simple framework for Kafka consumers in Ruby

A resilient Ethereum event listener that bridges your smart contract events and backend microservices

基于Gradle构建，使用SpringBoot在各个场景的应用，包括集成消息中间件、前后端分离、数据库、缓存、分布式锁、分布式事务等

Kafka storage rebalancing, automated replication throttle, cluster API and more

用java实现一下Logstash的几个常用input/filter/output, 希望能有效率上面的大提升. 现在我们迁移到golang了 https://github.com/childe/gohangout

Very simplified insurance sales system made in a microservices architecture using Micronaut

Propan is a powerful and easy-to-use Python framework for building event-driven applications that interact with any MQ Broker

A blazing fast tool for building data pipelines: read, process and output events. Our community: https://t.me/file_d_community

GlassFlow: Open source data ingestion and transformations for ClickHouse pipelines

ReplicaDB is open source tool for database replication, designed for efficiently transferring bulk data between relational and non-relational database...

基于 Springboot + Redis + Kafka 的秒杀系统，乐观锁 + 缓存 + 限流 + 异步，TPS 从 500 优化到 3000

Framework for automated integration tests with focus on message-based applications

Apache Camel Examples