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

.NET Stream Processing Library for Apache Kafka 🚀

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

UNMAINTAINED! - Complete Google Analytics, Mixpanel, KISSmetrics (and more) integration for JavaScript applications.

SpringBoot 整合各类框架和应用

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

Kalium: a reactive framework for micro-services

RabbitMQ Bundle for the Symfony2 web framework

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

Apache Kafka running on Kubernetes

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

The purpose of this tiny project is to put things together with the know how that i learned from the course big data expert from formacionhadoop.com The idea is to show how to play with apache spark streaming, kafka,mongo, spark machine learning algorithms.

A Kafka Operator for Kubernetes

Blockchain data parsing and persisting results

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

Yet another Web UI for KSQL

A native Node.js producer and consumer library for Amazon Kinesis Data Streams

Streaming data changes to a Data Lake with Debezium and Delta Lake pipeline

大数据分析可视化实践

SparkStreaming中利用MySQL保存Kafka偏移量保证0数据丢失

A toolset to use Segments open-source analytics library (analytics.js) WITHOUT using the paid Segment service (segment.com). To be used with your favorite analytics-tools like Google Analytics, Mixpanel, Hotjar, etc.

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

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

A library provides consumer/producer to work with kafka, avro and schema registry

This is an example of real time stream processing using Spark Streaming, Kafka & Elasticsearch.

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

Divolte Collector

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.

[DEPRECATED] Docker images for Confluent Platform.

CodeIgniter 3 Daemon Queue Worker (Consumer) Management Controller

Swipeable SegmentedControl component for React Native apps

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

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

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

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

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

必看！java后端，亮剑诛仙。java发展路线技术要点。

Apollo graphql subscriptions over Kafka protocol

Apache Kafka support for Ruby Object Mapper

Enables your consumer driven contracts workflow

Distributed Stream and Batch Processing

Kafka Connect suite of connectors for Cloud storage (Amazon S3)

Spring Boot application showing basic configuration to work with Kafka

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

Spring Boot 2.x code examples

This Scrapy project uses Redis and Kafka to create a distributed on demand scraping cluster.

StreamLine - Streaming Analytics

A resilient and scalable shopping cart system designed using Event Sourcing (ES) and Command Query Responsibility Segregation (CQRS)

Curated by Lenses.io

Monitoring tool to measure flow throughput of data sources and processing components that are part of Data Ingestion and ETL pipelines.

🥚 Netty实践学习案例，见微知著！带着你的心，跟着教程。我相信你行欧。

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

Command Dispatcher, Processor, and Distributed Task Queue

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

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

A easy and high-performance monitoring system, for comprehensive monitoring and management of kafka cluster.

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