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 and Talks. ⚠️Might be rough around the edges ;-) 👉For automated tutorials and QA'd code, see https://github.com/confluentinc/examples/

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!

infoslack/awesome-kafka

A list about Apache Kafka

hypertrace/hypertrace

An open source distributed tracing & observability platform

kafbat/kafka-ui

Open-Source Web UI for managing Apache Kafka clusters

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

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.

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

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