414 Open source projects that are alternatives of or similar to Sarama

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

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

A CLI and Go client for Kafka Schema Registry

Kafka-based message queue

Spring Boot 2.x code examples

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

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

StorageTapper is a scalable realtime MySQL change data streaming, logical backup and logical replication service

a Rocket-fast SYStem for LOG processing

Simple learning project pushing CSV data into Kafka then indexing the data in ElasticSearch

Oryx 2: Lambda architecture on Apache Spark, Apache Kafka for real-time large scale machine learning

550+ DevOps Bash Scripts - AWS, GCP, Kubernetes, Kafka, Docker, APIs, Hadoop, SQL, PostgreSQL, MySQL, Hive, Impala, Travis CI, Jenkins, Concourse, GitHub, GitLab, BitBucket, Azure DevOps, TeamCity, Spotify, MP3, LDAP, Code/Build Linting, pkg mgmt for Linux, Mac, Python, Perl, Ruby, NodeJS, Golang, Advanced dotfiles: .bashrc, .vimrc, .gitconfig, .screenrc, .tmux.conf, .psqlrc ...

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

The database purpose-built for stream processing applications.

大数据入门指南 ⭐

Learn Clean Architecture with .NET Core 3.0 🔥

A python wrapper for the KSQL REST API.

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

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

Apache Kafka on Docker

A Clojure DSL for Kafka Streams

DDD. Event sourcing. CQRS. REST. Modular. Microservices. Kotlin. Spring. Axon platform. Apache Kafka. RabbitMQ

kafka php client

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

Distributed Prometheus time series database

大数据学习，从零开始学习大数据，包含大数据学习各阶段学习视频、面试资料

A set of tools and examples to run a flow-pipeline (sFlow, NetFlow)

Big Data Processing Framework - Unified Data API or SQL on Any Storage

以Kafka为存储介质，提供异步Http RPC的中间件

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

.NET event stream projection and scheduling platform with EventStore, CosmosDb, Equinox and Kafka integrations

Health Check for Kafka Brokers.

A bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.

A cohesive & pragmatic framework of FP centric Scala libraries

A high performance/ real-time C++ Kafka streams framework (C++17)

Go driver for Kafka

Kasper is a lightweight library for processing Kafka topics.

Instagram Clone - Cloning Instagram for learning purpose

Go client library for Apache Kafka

Confluent Platform Demo including Apache Kafka, ksqlDB, Control Center, Replicator, Confluent Schema Registry, Security

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

Event sourcing with kafka and nodejs

Kafka connect Elastic sink connector, with just in time index/delete behaviour.

Golang app to read records from a set of kafka topics and write them to an elasticsearch cluster

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

A real-time data replication platform that "unbundles" the receiving, transforming, and transport of data streams.

Kafka Connect HDFS connector

golang kafka consumer group

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

Real-time analysis of bitcoin markets with Kafka and Tensorflow Serving

DoctorK is a service for Kafka cluster auto healing and workload balancing

Big Data Toolkit for the JVM

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

MySQL to NoSQL real time dataflow

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

Distributed Stream and Batch Processing

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

High performance mqtt broker

Logback appender for Apache Kafka