549 Open source projects that are alternatives of or similar to Java Kafka Client

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

以教学为目的的电商系统。包含ToB复杂业务、互联网高并发业务、缓存应用；DDD、微服务指导。模型驱动、数据驱动。了解大型服务进化路线，编码技巧、学习Linux，性能调优。Docker/k8s助力、监控、日志收集、中间件学习。前端技术、后端实践等。主要技术：SpringBoot+JPA+Mybatis-plus+Antd+Vue3。

A Kafka Operator for Kubernetes

The Kafka CLI for humans

The high-scalability sFlow/NetFlow/IPFIX collector used internally at Cloudflare.

Asky开源架构：极简、轻量、极致性能《Asky零基础1小时学编程 dnc+vue+tidb+redis+rabbitMQ+ES》QQ群 779699538

Bridge between OpenTracing and Brave

基于Spring Cloud（Greenwich.SR2）搭建的微服务脚手架（适用于在线系统），已集成注册中心（Nacos Config）、配置中心（Nacos Discovery）、认证授权（Oauth 2 + JWT）、日志处理（ELK + Kafka）、限流熔断（AliBaba Sentinel）、应用指标监控（Prometheus + Grafana）、调用链监控（Pinpoint）、以及Spring Boot Admin。

Distributed Named Pipes

Sample Application DDD, Reactive Microservices, CQRS Event Sourcing Powered by DERMAYON LIBRARY

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]

Java源码分析 【源码笔记】专注于Java后端系列框架的源码分析，每周持续推出Java后端系列框架的源码分析文章。

Kafka Development Tool

A Manageable, Measurable and Traceable Node.js Application Manager represented by Alibaba powered by TypeScript

QMQ是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景； 也包括报价搜索等高吞吐量场景。

springboot和dubbo、netty的集成，redis mongodb的nosql模板， kafka rocketmq rabbit的MQ模板， solr solrcloud elasticsearch查询引擎

The database purpose-built for stream processing applications.

De-/Serialization wrapper for Kafka to accomplish end to end encryption

A CLI tool for Kafka

推荐项目（实时推荐和离线推荐）

🎉🎉🎉JAVA高级架构师技术栈==任何技能通过 “刻意练习” 都可以达到融会贯通的境界，就像烹饪一样，这里有一份JAVA开发技术手册，只需要增加自己练习的次数。🏃🏃🏃

Serverless Platform for the stateful services

Automated documentation for async APIs built with Spring Boot

Reactive (RSocket/gRPC) Gateway for the event-based systems

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

前端性能监控系统,消息队列,高可用,集群等相关架构

MOVED TO https://github.com/opentracing/opentracing-php

Surging is a micro-service engine that provides a lightweight, high-performance, modular RPC request pipeline. The service engine supports http, TCP, WS,Grpc, Thrift,Mqtt, UDP, and DNS protocols. It uses ZooKeeper and Consul as a registry, and integrates it. Hash, random, polling, Fair Polling as a load balancing algorithm, built-in service gove…

A real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernetes deployed on the cloud

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

Kasper is a lightweight library for processing Kafka topics.

High throughput asynchronous task processing on Apache Kafka

Karapace - Your Kafka essentials in one tool

Schema Registry

Go web framework Echo example. 在线演示☞迁移ing❌

OpenTracing instrumentation for Vert.x web package

Kafka consumer lag-checking application for monitoring, written in Scala and Akka HTTP; a wrap around the Kafka consumer group command. Integrations with Cloudwatch and Datadog. Authentication recently added

Support for deploying Jaeger into Kubernetes

Self-contained examples of Apache Spark streaming integrated with Apache Kafka.

💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算)；🚀 支持运行过程中增删topic；🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。

KafkaCenter is a unified platform for Kafka cluster management and maintenance, producer / consumer monitoring, and use of ecological components.

Experimental CQRS and Event Sourcing service

SOFATracer is a component for the distributed system call trace. And through a unified traceId logging the logs of various network calls in the invoking link. These logs can be used for quick discovery of faults, service governance, etc.

《Kafka技术内幕》代码

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

个人学习知识库涉及到数据仓库建模、实时计算、大数据、Java、算法等。

Collection of Kubernetes Operators built with KUDO.

Attach hooks to any database/sql driver

Ansible playbooks for the Confluent Platform

MySQL to NoSQL real time dataflow

一个仿照牛客网实现的讨论社区，不仅实现了基本的注册，登录，发帖，评论，点赞，回复功能，同时使用前缀树实现敏感词过滤，使用wkhtmltopdf生成长图和pdf，实现网站UV和DAU统计，并将用户头像等信息存于七牛云服务器。

Flume NG Canal source

Very simplified shop sales system made in a microservices architecture using quarkus

C# client (tracer) for Jaeger

A stream processing framework to build stateless applications on Kafka

深圳地铁大数据客流分析系统🚇🚄🌟

Fancy stream processing made operationally mundane

提供各种客户端接入阿里云 消息队列 Kafka 的demo工程

销售系统项目，spring+spring mvc+mybatis+dubbo+kafka+redis+maven