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

A list about Apache Kafka

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

Demo applications and code examples for Confluent Platform and Apache Kafka

Kattlo CLI Project

A lightweight stream processing library for Go

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

Materials (slides and code) for Kafka and Kafka Streams Workshop

🚀 Azkarra is a lightweight java framework to make it easy to develop, deploy and manage cloud-native streaming microservices based on Apache Kafka Streams.

equivalent to kafka-streams 🐙 for nodejs ✨🐢🚀✨

Python Stream Processing

A REPL for Apache Kafka

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.

Open-Source Web GUI for Apache Kafka Management

Fancy stream processing made operationally mundane

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

Wirbelsturm is a Vagrant and Puppet based tool to perform 1-click local and remote deployments, with a focus on big data tech like Kafka.

Kasper is a lightweight library for processing Kafka topics.

🚀 Web GUI for Kafka Cluster Management

Modern C++ Apache Kafka client library (wrapper for librdkafka)

Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.

Samsara is a real-time analytics platform

Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.

Learn Kafka Streams with several examples!

Kafka command line tool that likes JSON

The database purpose-built for stream processing applications.

Distributed Stream and Batch Processing

👾Scripts and samples to support Confluent Demos and Talks. ⚠️Might be rough around the edges ;-) 👉For automated tutorials and QA'd code, see https://github.com/confluentinc/examples/

Apache Kafka on Docker

Complex Event Processing on top of Kafka Streams

No description or website provided.

Azure Event Hubs for Apache Kafka Ecosystems

This repository contains a set of examples to be used with Red Hat AMQ messaging suite components.

Kafka Connect HDFS connector

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

No description or website provided.

The Apache Kafka C/C++ library

Kafka-based Job Queue for Python

A collection of kafka-resources

Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.

This project contains examples which demonstrate how to deploy analytic models to mission-critical, scalable production environments leveraging Apache Kafka and its Streams API. Models are built with Python, H2O, TensorFlow, Keras, DeepLearning4 and other technologies.

This repository contains the code base for the Open Stream Processing Benchmark.

Yet another Web UI for KSQL

Apache Kafka Web UI for exploring messages, consumers, configurations and more with a focus on a good UI & UX.

Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.

Kafka client for functional streams for scala (fs2)

Framework for Apache Kafka based Ruby and Rails applications development.

[DEPRECATED] Docker images for Confluent Platform.

Ship changes in Postgres 🐘 to Kafka 📖

Files needed to try out KSQL Recipes for yourself

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

OpenTracing Instrumentation for Apache Kafka Client

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

WaterDrop is a standalone Karafka component library for generating Kafka messages

Neo4j Kafka Integrations, Docs =>

Event-Driven microservices with Kafka Streams

Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.

This toolkit is focused on interacting with popular messaging systems such as Kafka, JMS, XMS, and MQTT. After release v5.4.2 the complete toolkit will be deprecated. See the README.md file for hints to alternative toolkits.

A Clojure DSL for Kafka Streams