kafka

spring、spring-boot、spring-cloud 常用整合用例

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

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

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

以教学为目的的电商系统。包含ToB复杂业务、互联网高并发业务、缓存应用；DDD、微服务指导。模型驱动、数据驱动。了解大型服务进化路线，编码技巧、学习Linux，...

Code for Agile Data Science 2.0, O'Reilly 2017, Second Edition

一个仿照牛客网实现的讨论社区，不仅实现了基本的注册，登录，发帖，评论，点赞，回复功能，同时使用前缀树实现敏感词过滤，使用wkhtmltopdf生成长图和pdf，实现...

Get a stream of issues and pull requests for your chosen GitHub repository

Distributed Named Pipes

Kafka Connect HDFS connector

Easily load data from kafka to ClickHouse

Zeek Analysis Tools (ZAT): Processing and analysis of Zeek network data with Pandas, scikit-learn, Kafka and Spark

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

🐳✨ Fully automated Apache Kafka® and Confluent Docker based examples // 👷‍♂️ Easily build examples or reproduction models

This repo maintains DM (a data migration platform) and TiCDC (change data capture for TiDB)

Kasper is a lightweight library for processing Kafka topics.

Racecar: a simple framework for Kafka consumers in Ruby

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

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

Kafka 中文文档

Terraform provider for managing Apache Kafka Topics + ACLs

2022java面试题、JVM面试题、多线程面试题、并发编程、Redis面试题、MySQL面试题、Java2022面试题、Netty面试题、Elasticsearch面试题、Tomcat面试题、Dubbo面试...

我的个人技术博客（Python、Django、Docker、Go、Redis、ElasticSearch、Kafka、Linux）

:rocket: Web GUI for Kafka Cluster Management

Modern real-time chat in scalable architecture.

Real Time Big Data / IoT Machine Learning (Model Training and Inference) with HiveMQ (MQTT), TensorFlow IO and Apache Kafka - no additional data store...

Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar

Streaming reactive and dataflow graphs in Python

kratos transport layer extension

Web tool for Avro Schema Registry |

Kafka UI and Monitoring Tool

💬 Open Source App Framework to build streaming apps with real-time data - 💎 Build real-time data pipelines and make real-time data universally acc...

DeviceHive Java Server

Full-featured web-based Apache Kafka consumer UI

Example microservices showing how to use Kafka and Kafka Streams with Spring Boot on the example of distributed transactions implementations with the...

.NET Stream Processing Library for Apache Kafka 🚀

提供各种客户端接入阿里云 消息队列 Kafka 的demo工程(Provide a demo project for various clients to access Alibaba Cloud message queue Kafka)

An Open-Source Collection of 230+ Flash Cards to Help You Succeed in Your System Design Interview and More 💯

A solution to help you build automation and gitops in your Apache Kafka deployments. The Kafka gitops!

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

StorageTapper is a scalable realtime MySQL change data streaming, logical backup and logical replication service

Scala helper modules for operating the Apache Kafka client library (0.9.x - 2.1.0)

Sync data from the other DB to ClickHouse(cluster)

Gathers scalable Tensorflow, Python infrastructure deployment and practices, 100% Docker.

Quarkus sample application - Super Heroes

Firehose is an extensible, no-code, and cloud-native service to load real-time streaming data from Kafka to data stores, data lakes, and analytical st...

Kafka Source Connector For Oracle

MQTTX Project 完整实现 mqttv3.1.1 协议，旨在提供易于使用且性能优异的 mqtt broker

Manage your Kafka ACL at scale

Kafka-based message queue