kafka

Apache Kafka client library for Erlang/Elixir

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

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

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

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.

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)

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

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.

Karapace - Your Apache Kafka® essentials in one tool

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

A curated list of Apache Kafka learning resources

Terraform provider for managing Apache Kafka Topics + ACLs

A cohesive & pragmatic framework of FP centric Scala libraries

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

Venice, Derived Data Platform for Planet-Scale Workloads.

Kafka client library for Elixir

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

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

Community driven, reusable components for distributed apps

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

A list about Apache Kafka

Sample Event Sourcing implementation with .NET Core

Kafka-based Job Queue for Python

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

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

Instagram Clone - Cloning Instagram for learning purpose

.NET Stream Processing Library for Apache Kafka 🚀

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

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

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

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

GlassFlow ETL: 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...

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

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

用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

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

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