496 Open source projects that are alternatives of or similar to Kafka Go

Streaming reference architecture for ETL with Kafka and Kafka-Connect. You can find more on http://lenses.io on how we provide a unified solution to manage your connectors, most advanced SQL engine for Kafka and Kafka Streams, cluster monitoring and alerting, and more.

A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues

DeviceHive Java Server

High performance mqtt broker

汇总java生态圈常用技术框架、开源中间件，系统架构、数据库、大公司架构案例、常用三方类库、项目管理、线上问题排查、个人成长、思考等知识

A convenience library for Apache Kafka integration in a Dropwizard service.

Spring Boot application showing basic configuration to work with Kafka

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

Spring Boot 2.x code examples

Free and open source log management

Kafka Tutorials microsite

Building event-driven applications the easy way in Go.

Apache Kafka on Docker

Python Stream Processing

CGA 3D 计算几何算法库 | 3D Compute Geometry Algorithm Library webgl three.js babylon.js等任何库都可以使用

Learn Kafka Streams with several examples!

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

A lightweight stream processing library for Go

docker-compose.yml files for cp-all-in-one , cp-all-in-one-community, cp-all-in-one-cloud

gRPC/REST proxy for Kafka

Confluent REST Proxy for Kafka

分布式架构开发套件。包括缓存(一二级缓存、自动缓存管理)、队列、分布式定时任务、文件服务(七牛、阿里云OSS、fastDFS)、日志、搜索、分布式锁、分布式事务、集成dubbo、spring boot支持以及常用的工具包等。

Akshay Rangesh and Mohan M. Trivedi, "HandyNet: A One-stop Solution to Detect, Segment, Localize & Analyze Driver Hands," IEEE Conference on Computer Vision and Pattern Recognition - 3D HUMANS Workshop, 2018.

java-study 是本人学习Java过程中记录的一些代码！从Java基础的数据类型、jdk1.8的Lambda、Stream和日期的使用、 IO流、数据集合、多线程使用、并发编程、23种设计模式示例代码、常用的工具类， 以及一些常用框架，netty、mina、springboot、kafka、storm、zookeeper、redis、elasticsearch、hbase、hive等等。

Syslog Collector written in Go, streams to Kafka 0.8

Yivnet is a microservice game server base on go-kit

Command Dispatcher, Processor, and Distributed Task Queue

**Unofficial / Community** Kafka Connect MongoDB Sink Connector - Find the official MongoDB Kafka Connector here: https://www.mongodb.com/kafka-connector

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

Java生态研究(Spring Boot + Redis + Dubbo + RocketMQ + Elasticsearch)🔥🔥🔥🔥🔥

本项目已迁移至 github.com/jetlinks

Real Time Analytics and Data Pipelines based on Spark Streaming

Secor is a service implementing Kafka log persistence

golang版本的hangout, 希望能省些内存. 使用了自己写的Kafka lib .. 虚. 不过我们在生产环境已经使用近1年, kafka 版本从0.9.0.1到2.0都在使用, 目前情况稳定. 吞吐量在每天2000亿条以上.

Streaming reactive and dataflow graphs in Python

Apache Kafka client library for Erlang/Elixir

Node.js bindings for librdkafka

Oh no! Yet another Kafka operator for Kubernetes

A simple local reverse proxy server for HLS segment cache

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

Extended datasource support for Spark/Hadoop on Aliyun E-MapReduce.

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

syncClient，数据实时同步中间件（同步mysql到kafka、redis、elasticsearch、httpmq）！

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

Community driven, reusable components for distributed apps

Distributed Named Pipes

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

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

Metronome is a distributed and fault-tolerant event scheduler

The database purpose-built for stream processing applications.

Materialize lets you ask questions of your live data, which it answers and then maintains for you as your data continue to change. The moment you need a refreshed answer, you can get it in milliseconds. Materialize is designed to help you interactively explore your streaming data, perform data warehousing analytics against live relational data, or just increase the freshness and reduce the load of your dashboard and monitoring tasks.

Avro SerDe for Apache Spark structured APIs.

Full-featured web-based Apache Kafka consumer UI

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

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 REPL for Apache Kafka

kafka .net core library

Consumer Banking Application

Serverless Platform for the stateful services

a Rocket-fast SYStem for LOG processing