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

Collection of Kubernetes Operators built with KUDO.

Use Kafka as a remote storage database for Prometheus (remote write only)

Schema Registry

《Kafka技术内幕》代码

Confluent's Apache Kafka .NET client

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

Mirus is a cross data-center data replication tool for Apache Kafka

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

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

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

Simplifying Kafka for ruby apps

Apollo graphql subscriptions over Kafka protocol

Thin Scala wrapper around Kafka Streams Java API

Write your Spark data to Kafka seamlessly

♒︎ [WIP] An experimental ~distributed~ commit-log

.NET Stream Processing Library for Apache Kafka 🚀

High throughput asynchronous task processing on Apache Kafka

Spark Structured Streaming / Kafka / Cassandra / Elastic

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

大数据分析可视化实践

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

本人的RabbitMQ和Kafka详细笔记以及示例代码

Serverless Platform for the stateful services

Laravel Enqueue message queue extension. Supports AMQP, Amazon SQS, Kafka, Google PubSub, Redis, STOMP, Gearman, Beanstalk and others

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

Command Line Tool for managing Apache Kafka

Redpanda is the real-time engine for modern apps. Kafka API Compatible; 10x faster 🚀 See more at vectorized.io/redpanda

C# 开发辅助类库，和士官长一样身经百战且越战越勇的战争机器，能力无人能出其右。

A complete example of a big data application using : Kubernetes (kops/aws), Apache Spark SQL/Streaming/MLib, Apache Flink, Scala, Python, Apache Kafka, Apache Hbase, Apache Parquet, Apache Avro, Apache Storm, Twitter Api, MongoDB, NodeJS, Angular, GraphQL

Apache Kafka running on Kubernetes

Kafka web UI

Kafka Web UI

light, fast, scalable, streaming microservices made easy

Real Time Big Data / IoT Machine Learning (Model Training and Inference) with HiveMQ (MQTT), TensorFlow IO and Apache Kafka - no additional data store like S3, HDFS or Spark required

Java SDK for CloudEvents

后端面试题汇总（Python、Redis、MySQL、PostgreSQL、Kafka、数据结构、算法、编程、网络）

A search framework and multi-tenant search platform based on java, kafka, kafka connect, elasticsearch

franz-go contains a high performance, pure Go library for interacting with Kafka from 0.8.0 through 2.7.0+. Producing, consuming, transacting, administrating, etc.

一站式Apache Kafka集群指标监控与运维管控平台

mq transaction, tcc, eventually consistency. tx life cycle: all listeners handled, if necessary, produce next message

Source code for the Kafka Streams in Action Book

⚡️ Nepxion Thunder is a distribution RPC framework based on Netty + Hessian + Kafka + ActiveMQ + Tibco + Zookeeper + Redis + Spring Web MVC + Spring Boot + Docker 多协议、多组件、多序列化的分布式RPC调用框架

MongoDB Kafka Connector

A simple way to publish messages to Kafka from Ruby applications

DC/OS SDK is a collection of tools, libraries, and documentation for easy integration of technologies such as Kafka, Cassandra, HDFS, Spark, and TensorFlow with DC/OS.

amazonriver 是一个将postgresql的实时数据同步到es或kafka的服务

An Hexagonal Architecture with DDD + Aggregates + Event Sourcing using .NET Core, Kafka e MongoDB (Blog Engine)

OpenMessaging Benchmark Framework

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

💪 example of common used libraries and frameworks, programming required, don't fork man.

我,请始皇[打钱]是一个前后端分离的工具人系统，项目采用 SpringBoot+Go+Vue 开发，项目加入常见的企业级应用所涉及到的技术点，例如 Redis、RabbitMQ 等(主要是多用用工具多踩踩坑)。

Apache Kafka load testing "...basically a cloth bag filled with small jagged pieces of scrap iron"

Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.

istio 微服务示例代码 grpc+protobuf+echo+websocket+mysql+redis+kafka+docker-compose

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

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

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

Sync data from the other DB to ClickHouse(cluster)

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

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