kafka-streams

robinhood/faust

Python Stream Processing

strimzi/strimzi-kafka-operator

Apache Kafka® running on Kubernetes

memgraph/memgraph

Open-source graph database, tuned for dynamic analytics environments. Easy to adopt, scale and own.

reugn/go-streams

A lightweight stream processing library for Go

confluentinc/demo-scene

Scripts and samples to support Confluent Demos, Talks, and Blogs. Not all of the examples in this repository are kept up to date. For automated tutorials and QA'd code, see https://github.com/confluentinc/tutorials/

SeldonIO/seldon-server

Machine Learning Platform and Recommendation Engine built on Kubernetes

danielealbano/cachegrand

cachegrand - a modern data ingestion, processing and serving platform built for today's hardware

speedb-io/speedb

A RocksDB compliant high performance scalable embedded key-value store

kaiwaehner/kafka-streams-machine-learning-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.

nodefluent/kafka-streams

equivalent to kafka-streams :octopus: for nodejs :sparkles::turtle::rocket::sparkles:

simplesteph/kafka-streams-course

Learn Kafka Streams with several examples!

kafbat/kafka-ui

Open-Source Web UI for managing Apache Kafka clusters

infoslack/awesome-kafka

A list about Apache Kafka

hypertrace/hypertrace

An open source distributed tracing & observability platform

LGouellec/streamiz

.NET Stream Processing Library for Apache Kafka 🚀

kaiwaehner/hivemq-mqtt-tensorflow-kafka-realtime-iot-machine-learning-training-inference

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

gojek/ziggurat

A stream processing framework to build stateless applications on Kafka

airyhq/airy

💬 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

wintoncode/winton-kafka-streams

A Python implementation of Apache Kafka Streams

fhussonnois/kafkastreams-cep

Complex Event Processing on top of Kafka Streams

piomin/sample-spring-kafka-microservices

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

microsoft/data-accelerator

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.

manub/scalatest-embedded-kafka

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

lightbend/kafka-with-akka-streams-kafka-streams-tutorial

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

monksy/awesome-kafka

A collection of kafka-resources

juicycleff/nestjs-event-store

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

lightbend/kafka-streams-scala

Thin Scala wrapper around Kafka Streams Java API

jpzk/mockedstreams

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

streamthoughts/azkarra-streams

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

framiere/a-kafka-story

Kafka ecosystem ... but step by step!

hortonworks/streamline

StreamLine - Streaming Analytics

LearningJournal/Kafka-Streams-Real-time-Stream-Processing

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

zakariamaaraki/RemoteCodeCompiler

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.

ppatierno/formula1-telemetry-kafka

kaiwaehner/tensorflow-serving-java-grpc-kafka-streams

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