Top 60 kafka-streams open source projects

Data Accelerator for Apache Spark simplifies onboarding to Streaming of Big Data. It offers a rich, easy to use experience to help with creation, editing and management of Spark jobs on Azure HDInsights or Databricks while enabling the full power of the Spark engine.

Open-Source Web GUI for Apache Kafka Management

Code samples for the Lightbend tutorial on writing microservices with Akka Streams, Kafka Streams, and Kafka

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

Apache Kafka running on Kubernetes

Thin Scala wrapper around Kafka Streams Java API

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

.NET Stream Processing Library for Apache Kafka 🚀

StreamLine - Streaming Analytics

Kafka ecosystem ... but step by step!

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

Kafka Tutorials microsite

A collection of kafka-resources

Machine Learning Platform and Recommendation Engine built on Kubernetes

A REPL for Apache Kafka

OpenTracing Instrumentation for Apache Kafka Client

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.

A Clojure DSL for Kafka Streams

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

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

Kattlo CLI Project

Demo applications and code examples for Confluent Platform and Apache Kafka

Yet another Web UI for KSQL

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

[DEPRECATED] Docker images for Confluent Platform.

👾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/

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.

Python Stream Processing

Learn Kafka Streams with several examples!

A lightweight stream processing library for Go

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

A list about Apache Kafka

A Python implementation of Apache Kafka Streams

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

A stream processing framework to build stateless applications on Kafka

Complex Event Processing on top of Kafka Streams

No description or website provided.

Kafka, Debezium and Fuse demonstration based on Chuck Norris movies!

Framework for building distributed microserviceies in scala with akka-streams and kafka

Library offering http based query on top of Kafka Streams Interactive Queries

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

Demonstrations for Kafka with Spring Boot

Kafka End to End Encryption

Kafka Streams based microservice

No description or website provided.

Redis Kafka Streams State Store

Sample Spring Cloud microservices e-shop.

Kafka with KafkaReactor and Kafka Streams Examples in Kotlin

Kafka Streams demo project containing Derivative Events, the Processor Api and Wall-clock examples

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

Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.

Event Sourcing(CQRS) and Materialized views with Kafka Streams

Event-Driven microservices with Kafka Streams

Twitter Streaming API Example with Kafka Streams in Scala

Terraform and Ansible to install a Kafka Cluster

Examples of Avro, Kafka, Schema Registry, Kafka Streams, Interactive Queries, KSQL, Kafka Connect in Scala

An umbrella project for multiple implementations of model serving

Kafka Streams DSL vs Processor API

Plumber, for your dirtiest Kafka streaming jobs