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

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

Golang Kafka consumer and producer example

一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024

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

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

Machine Learning Platform and Recommendation Engine built on Kubernetes

Manage your topic's configuration (partitions, replication factor, parameters), ACLs, quotas, and get stats, without any effort with this library. It does not use the Kafka scripts and does not require ssh connection to the remote broker.

Sync data from the other DB to ClickHouse(cluster)

syslog-ng is an enhanced log daemon, supporting a wide range of input and output methods: syslog, unstructured text, queueing, SQL & NoSQL.

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

Monorepo housing Segment's analytics.js integrations

Dumps state of Storm Kafka consumers

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

A web client for visualizing your Apache Kafka topics live.

A client UI to inspect Kafka topics, consume, produce and much more

Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.

Kafka Web UI

kafka-connect-s3 : Ingest data from Kafka to Object Stores(s3)

Implementing a Web Based solution through which farmers can participate in a commodity exchange market

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

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

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

Example end to end data engineering project.

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

Kafka backed service library.

An opinionated Elixir wrapper around brod, the Erlang Kafka client, that supports encrypted connections to Heroku Kafka out of the box.

关于kafka的一些相关使用示例代码。

A simple way to publish messages to Kafka from Ruby applications

Android SDK for Wootric Survey Platform supporting NPS, CSAT and CES surveys

Apache Kafka running on Kubernetes

Superman是什么：构建Java 高级开发技术的知识体系，从基础不断打怪升级成为超人之路（更新中.......）

Mirror of Linkedin's Camus

OpenMessaging Benchmark Framework

Protobuf converter plugin for Kafka Connect

High performance Kafka consumer for InfluxDB. Supports collectd message formats.

A library that provides an in-memory Kafka instance to run your tests against.

This is a Platform that collects all the data accuring in your Application and shows the data in real time by using Kibana or other tools.

CodeIgniter 3 Daemon Queue Worker (Consumer) Management Controller

Swipeable SegmentedControl component for React Native apps

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

Kafka 한국 사용자 모임에서 운영하는 meetup repository

Drain log template miner in Python3

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

This is a NodeJS/Angular 2 frontend UI for Kafka cluster monitoring with Burrow

An Event Sourcing service template with DDD, TDD and SOLID. It has High Cohesion and Loose Coupling, it's a good start for your next Microservice application.

Open-source IoT Platform - Device management, data collection, processing and visualization.

Ansible Kafka role

《Kafka技术内幕》代码

Automated documentation for async APIs built with Spring Boot

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

A CLI and Go client for Kafka Schema Registry

Spring Boot application showing basic configuration to work with Kafka

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

Spring Boot 2.x code examples

Command Dispatcher, Processor, and Distributed Task Queue

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

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

Write your Spark data to Kafka seamlessly

Full-featured web-based Apache Kafka consumer UI