561 Open source projects that are alternatives of or similar to Kafka Tutorials

A web client for visualizing your Apache Kafka topics live.

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

Automated documentation for async APIs built with Spring Boot

python通用分布式函数调度框架 pip install function_scheduling_distributed_framework

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

A real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernetes deployed on the cloud

Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.

weiboAd Infrastructure Data Processor : kafka consumer embedded Lua scripting language in data process framework

A project for developing tutorials for Streams

Simple Event Driven Microservices with Spring Cloud Stream

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

Code and presentation for Strata Model Serving tutorial

前端性能监控系统,消息队列,高可用,集群等相关架构

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.

Sarama is a Go library for Apache Kafka 0.8, and up.

docker compose files to create a fully working kafka stack

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

When Apache Pulsar meets Apache Spark

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

A web clone of the card game Cards Against Humanity.

A Python stream processing engine modeled after Yahoo! Pipes

Kafka consumer lag monitor

Event sourcing for Akka Streams

A Ruby client library for Apache Kafka

🦄 开源社区系统：基于 SpringBoot + MyBatis + MySQL + Redis + Kafka + Elasticsearch + Spring Security + ... 并提供详细的开发文档和配套教程。包含帖子、评论、私信、系统通知、点赞、关注、搜索、用户设置、数据统计等模块。

Spring Boot 2.x code examples

kafka php client

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

My own version of r/place, done in a weekend

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

General purpose bitemporal database for SQL, Datalog & graph queries

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

Wayeb is a Complex Event Processing and Forecasting (CEP/F) engine written in Scala.

Metronome is a distributed and fault-tolerant event scheduler

Kafka Docker for development. Kafka, Zookeeper, Schema Registry, Kafka-Connect, Landoop Tools, 20+ connectors

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

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

a Rocket-fast SYStem for LOG processing

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

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.

Another app which used to monitor the progress of Kafka Producer and Consumer

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

Window-Based Hybrid CPU/GPU Stream Processing Engine

Apache Spark and Apache Kafka integration example

大数据入门指南 ⭐

a curated list of awesome streaming frameworks, applications, etc

Distributed Prometheus time series database

A python wrapper for the KSQL REST API.

Learn the Confluent Schema Registry & REST Proxy

KafkaFlow is a .NET framework to consume and produce Kafka messages with multi-threading support. It's very simple to use and very extendable. You just need to install, configure, start/stop the bus with your app and create a middleware/handler to process the messages.

Code to share the knowledge I gained while designing and implementing micro services

This library wraps Kafka's embedded test cluster, allowing you to more easily create and run integration tests using JUnit against a "real" kafka server running within the context of your tests. No need to stand up an external kafka cluster!

Example end to end data engineering project.

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

Kafka backed service library.

CMAK is a tool for managing Apache Kafka clusters

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

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