The Top 437 Kafka Streams Open Source Projects

Awesome Open Source

Share On Twitter

Combined Topics

kafka-streams x

The Top 437 Kafka Streams Open Source Projects

Categories > Data Processing > Kafka Streams

Faust ⭐ 6,245

Python Stream Processing

dependent packages 15total releases 46most recent commit 4 months ago

Kafka Ui ⭐ 4,105

Open-Source Web UI for Apache Kafka Management

most recent commit 20 hours ago

Strimzi Kafka Operator ⭐ 3,585

Apache Kafka® running on Kubernetes

dependent packages 2total releases 34most recent commit 20 hours ago

Seldon Server ⭐ 1,420

Machine Learning Platform and Recommendation Engine built on Kubernetes

total releases 44most recent commit 3 years ago

Demo Scene ⭐ 1,247

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

most recent commit a month ago

Go Streams ⭐ 1,082

A lightweight stream processing library for Go

dependent packages 9total releases 18most recent commit 2 months ago

Spring Cloud Stream Samples ⭐ 769

Samples for Spring Cloud Stream

most recent commit 7 months ago

Memgraph ⭐ 761

Open-source graph database, built for real-time streaming data, compatible with Neo4j.

most recent commit 20 hours ago

Kafka Streams ⭐ 728

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

dependent packages 6total releases 43most recent commit 8 months ago

Kafka Streams Machine Learning Examples ⭐ 632

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.

most recent commit 2 years ago

Kafka Streams Course ⭐ 528

Learn Kafka Streams with several examples!

most recent commit 3 years ago

Awesome Kafka ⭐ 514

A list about Apache Kafka

most recent commit 8 days ago

Hypertrace ⭐ 433

An open source distributed tracing & observability platform

most recent commit 2 months ago

Ziggurat ⭐ 364

A stream processing framework to build stateless applications on Kafka

total releases 71most recent commit 2 months ago

Kafka Streams Dotnet ⭐ 334

.NET Stream Processing Library for Apache Kafka 🚀

dependent packages 9total releases 23most recent commit 6 days ago

Airy ⭐ 318

💬 Open Source App Framework to build streaming apps with real-time data - 💎 Build real-time data pipelines and make real-time data universally accessible - 🤖 Join historical and real-time data in the stream to create smarter ML and AI applications. - ⚡ Standardize complex data ingestion and stream data to apps with pre-built connectors

dependent packages 2total releases 303most recent commit a day ago

Scalatest Embedded Kafka ⭐ 290

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

dependent packages 23total releases 15most recent commit 3 years ago

Winton Kafka Streams ⭐ 281

A Python implementation of Apache Kafka Streams

most recent commit 4 years ago

Data Accelerator ⭐ 279

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.

dependent packages 5total releases 26most recent commit a day ago

Kafka Tutorials ⭐ 249

Tutorials and Recipes for Apache Kafka

most recent commit 3 days ago

Kafkastreams Cep ⭐ 233

Complex Event Processing on top of Kafka Streams

most recent commit 3 years ago

Kafka Streams ⭐ 210

Code examples for working with Kafka Streams

most recent commit 6 years ago

Medium Blog Kafka Udemy ⭐ 208

Supporting repository for the blog post at https://medium.com/@stephane.maarek/how-to-use-apa

most recent commit a year ago

Kafka Streams Scala ⭐ 193

Thin Scala wrapper around Kafka Streams Java API

total releases 6most recent commit 4 years ago

Kafka With Akka Streams Kafka Streams Tutorial ⭐ 191

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

most recent commit 4 years ago

Kafka Streams In Action ⭐ 183

Source code for the Kafka Streams in Action Book

most recent commit a year ago

Mockedstreams ⭐ 182

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

dependent packages 1total releases 22most recent commit 2 years ago

Azkarra Streams ⭐ 168

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

dependent packages 5total releases 14most recent commit a year ago

Hivemq Mqtt Tensorflow Kafka Realtime Iot Machine Learning Training Inference ⭐ 159

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

most recent commit 2 years ago

Nestjs Event Store ⭐ 159

NestJS CQRS module for EventStore.org. It requires @nestjs/cqrs

dependent packages 1total releases 73most recent commit a month ago

npm @juicycleff/nestjs-event-store} Downloads

Streamline ⭐ 156

StreamLine - Streaming Analytics

total releases 183most recent commit 22 days ago

A Kafka Story ⭐ 144

Kafka ecosystem ... but step by step!

most recent commit 2 years ago

Awesome Kafka ⭐ 144

A collection of kafka-resources

most recent commit 10 months ago

Willa ⭐ 128

A Clojure DSL for Kafka Streams

total releases 5most recent commit 2 months ago

Logisland ⭐ 105

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.

dependent packages 34total releases 11most recent commit a year ago

Formula1 Telemetry Kafka ⭐ 105

most recent commit 2 months ago

Java Kafka Client ⭐ 102

OpenTracing Instrumentation for Apache Kafka Client

dependent packages 5total releases 35most recent commit 2 years ago

Kspp ⭐ 97

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

most recent commit 2 months ago

Kafka Streams Clojure ⭐ 95

Clojure transducers interface to Kafka Streams

most recent commit 5 years ago

Kafka Graphs ⭐ 94

Graph Analytics with Apache Kafka

dependent packages 1total releases 13most recent commit 13 days ago

Confluent Kafka Certification ⭐ 92

This repos is to keep all the relevant informations for Confluent Certified Developer for Apache Kafka (CCDAK)

most recent commit a year ago

Kukulcan ⭐ 91

A REPL for Apache Kafka

most recent commit 2 years ago

Kafkastreams4s ⭐ 90

Kafka Streams for Scala. Integrates KafkaStreams with the cats-effect ecosystem

dependent packages 4total releases 21most recent commit 22 days ago

Remotecodecompiler ⭐ 85

An online code compiler supporting 11 programming languages (Java, Kotlin, Scala, C, C++, C#, Golang, Python, Ruby, Rust and Haskell) for competitive programming and coding interviews.

most recent commit a day ago

Tensorflow Serving Java Grpc Kafka Streams ⭐ 85

Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response

most recent commit 3 years ago

Angularandspring ⭐ 83

This is an example application to show howto use Spring Boot 3, Angular 15, Kafka with Streams and Mongodb with the reactive features of Spring in a clean architecture and a Helm chart for the Kubernetes setup.

most recent commit 5 days ago

Fluent Kafka Streams Tests ⭐ 80

Fluent Kafka Streams Test with Java

dependent packages 5total releases 25most recent commit 2 months ago

Kafka Streams Real Time Stream Processing ⭐ 76

This is the central repository for all materials related to Kafka Streams : Real-time Stream Processing! Book by Prashant Pandey.

most recent commit 2 years ago

Springboot Kafka Connect Jdbc Streams ⭐ 73

The main goal is to play with Kafka Connect and Streams. We have store-api that inserts/updates records in MySQL; Source connectors that monitor inserted/updated records in MySQL and push messages related to those changes to Kafka; Sink connectors that read messages from Kafka and insert documents in ES; Store-streams that listens for messages in Kafka, treats them using Kafka Streams and push new messages back to Kafka.

most recent commit 3 months ago

Kafka Streams Workshop ⭐ 71

most recent commit 4 years ago

Kafka Streams Query ⭐ 67

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

total releases 2most recent commit 3 years ago

Microservice Patterns ⭐ 67

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

most recent commit 2 years ago

Kattlo Cli ⭐ 63

Kattlo CLI Project

most recent commit 2 years ago

Kafka Streams Ex ⭐ 61

A collection of examples and use-cases for Kafka Streams

most recent commit 6 years ago

Ksqldb Go ⭐ 59

A Golang client for ksqlDB

most recent commit a year ago

Awesome Opensource Contribs Kafka ⭐ 59

A list of all awesome open-source contributions for the Apache Kafka project

most recent commit a year ago

Kafka Workshop ⭐ 56

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

most recent commit 10 days ago

Clojure Kafka Examples ⭐ 55

Clojure examples for Kafka and Kafka Streams (JAVA Interop)

most recent commit a year ago

Mastering Kafka Streams And Ksqldb ⭐ 54

Code repository for the Mastering Kafka Streams and ksqlDB book

most recent commit 2 years ago

Ksqlsuite ⭐ 50

Node.js client for ksqlDB

total releases 6most recent commit 4 months ago

Kafka Serde Scala ⭐ 50

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

total releases 11most recent commit 10 months ago

E Shop ⭐ 50

Sample Spring Cloud microservices e-shop.

most recent commit a month ago

Kafka Streams Scala ⭐ 46

Thin Scala wrapper for the Kafka Streams API

most recent commit 5 years ago

Sample Spring Kafka Microservices ⭐ 46

Example microservices showing how to use Kafka and Kafka Streams with Spring Boot on the example of distributed transactions implementations with the SAGA pattern

most recent commit 10 months ago

Fdp Modelserver ⭐ 45

An umbrella project for multiple implementations of model serving

most recent commit 5 years ago

Twitterstream ⭐ 45

Twitter Streaming API Example with Kafka Streams in Scala

most recent commit 6 years ago

Kafka Scala Examples ⭐ 42

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

most recent commit 5 months ago

Kafka Encryption ⭐ 41

Kafka End to End Encryption

dependent packages 1total releases 2most recent commit 10 months ago

Kafka Streams Wordcount ⭐ 40

most recent commit 2 years ago

Noah ⭐ 39

Kafka Streams in Clojure

most recent commit a year ago

Tsujun ⭐ 39

Yet another Web UI for KSQL

most recent commit 4 years ago

Eye_of_sauron ⭐ 37

Stream processing using kafka-python to track people (user input images of target) in the wild over multiple video streams.

most recent commit 2 years ago

Kafka Streams ⭐ 34

most recent commit 6 years ago

Zipkin Storage Kafka ⭐ 33

Kafka-based storage for Zipkin.

dependent packages 1total releases 16most recent commit a year ago

Kafka Streams Api Websockets ⭐ 31

Live dashboard with data delivered via websockets and back-end processing managed by Apache Kafka.

most recent commit 5 years ago

Streams Explorer ⭐ 30

Explore Data Pipelines in Apache Kafka.

most recent commit 2 days ago

Amq Examples ⭐ 29

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

most recent commit 2 days ago

Hellhound ⭐ 28

A set of libraries to create asynchronous, high performance, scalable and simple application.

total releases 3most recent commit 2 years ago

Kafka Streams Running Topn ⭐ 27

Running Top N aggregation using Apache Kafka Streams

most recent commit 6 years ago

Football Events ⭐ 27

Event-Driven microservices with Kafka Streams

most recent commit 4 years ago

Kafka Streams Circe ⭐ 27

Generic Serdes with Circe for Kafka Streams

total releases 29most recent commit 5 months ago

Kafka Spark Flink Example ⭐ 26

Kafka streaming with Spark and Flink example

most recent commit 4 years ago

Kafka Streams Spring Boot Json Example ⭐ 26

Spring Boot example of how to read in JSON from a Kakfa topic and, via Kafka Streams, create a single json doc from subsequent JSON documents.

most recent commit 5 years ago

Circe Kafka ⭐ 26

Implicit conversion of Encoder and Decoder into Serializer/Deserializer/Serde

total releases 17most recent commit 20 days ago

Chuck Norris Streams ⭐ 25

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

most recent commit 7 months ago

Event Sourcing Kafka Streams ⭐ 24

Demo code from my talk @ Codemotion Milan 2018 - "Building event sourced systems with Kafka Streams"

most recent commit 4 years ago

Open Stream Processing Benchmark ⭐ 24

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

most recent commit a year ago

Strimzi.github.io ⭐ 22

Strimzi web site project

most recent commit a day ago

Awesome Kafka In Clojure ⭐ 22

Awesome information for using Kafka and Confluent Platform in Clojure.

most recent commit 4 years ago

Kafka Streams Plumber ⭐ 22

Plumber, for your dirtiest Kafka streaming jobs

most recent commit 6 years ago

Twitter Network Analysis ⭐ 22

Analyzing a network of tweets and retweets using graph algorithms

most recent commit 5 months ago

Typesafe Kafka Streams ⭐ 21

A started draft of a typesafe - scala - compatible API

total releases 5most recent commit 5 years ago

Kafka Streams Example ⭐ 21

Kafka Streams based microservice

most recent commit 6 years ago

Josef ⭐ 20

Process Kafka streams with Clojure Transducers

total releases 3most recent commit 6 years ago

Workflowgs ⭐ 20

Archive and manage your Sony RAW images

most recent commit 10 months ago

Kafkastream Cqrs Eventsourcing ⭐ 20

Event Sourcing(CQRS) and Materialized views with Kafka Streams

most recent commit 6 months ago

Kstream ⭐ 19

Apache Kafka Streams for Golang

most recent commit 6 months ago

Redisks ⭐ 18

Redis Kafka Streams State Store

most recent commit 5 years ago

Acp Admin Cloud ⭐ 18

使用 Kotlin 语言编写，基于 Spring Cloud 的微服务架构。该项目是前后端分离中的"后端部分"

most recent commit 9 months ago

Kstreams Des Demo ⭐ 17

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

most recent commit 3 years ago

1-100 of 437 projects

Next >