124 Open Source Kafka Streams Software Projects
Free and open source kafka streams code projects including engines, APIs, generators, and tools.
Kafka Streams Machine Learning Examples727 ⭐
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.
Kafka With Akka Streams Kafka Streams Tutorial205 ⭐
Code samples for the Lightbend tutorial on writing microservices with Akka Streams, Kafka Streams, and Kafka
Kafka Streams Query71 ⭐
Library offering http based query on top of Kafka Streams Interactive Queries
Kafka Streams Scala Starter Kit10 ⭐
This repository is a demonstration of how to use kafka-streams-scala from Lightbend in your scala code
Kafka Streams Emojitracker14 ⭐
Sample application for my talk 'Building Stateful Streaming Applications Without a Database'
Kafka Streams Spring Boot JSon Example27 ⭐
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.
Amq Examples22 ⭐
This repository contains a set of examples to be used with Red Hat AMQ messaging suite components.
Demo Scene1055 ⭐
👾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/
Hellosatish Microservice Patterns96 ⭐
Code to share the knowledge I gained while designing and implementing micro services
Event Sourcing Kafka Streams27 ⭐
Demo code from my talk @ Codemotion Milan 2018 - "Building event sourced systems with Kafka Streams"
Wearedevs 201812 ⭐
Code for my talk "Stateful & Reactive Streaming Applications Without a Database" at WeAreDevelopers 2018
Kafka Serde Scala50 ⭐
Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.
Tensorflow Serving Java Grpc Kafka Streams121 ⭐
Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response
Kafka Scala Examples37 ⭐
Examples of Avro, Kafka, Schema Registry, Kafka Streams, Interactive Queries, KSQL, Kafka Connect in Scala
Stream processing using kafka-python to track people (user input images of target) in the wild over multiple video streams.
Kafka Streams Real Time Stream Processing112 ⭐
This is the central repository for all materials related to Kafka Streams : Real-time Stream Processing! Book by Prashant Pandey.
Spring Reactive Microservices11 ⭐
spring-boot microservice example based on Spring Webflux, Apache Kafka, MongoDB, Docker
Springboot Kafka Connect Streams61 ⭐
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.
Data Accelerator258 ⭐
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.
"eCupcakesFactoryOnContainers" is based on a simplified "Microservices" architecture and docker containers. Core intent of this reference application is to provide reference implementation for .Net developers to easily get started with containerized microservices using .Net Core and Kafka.
Hivemq Mqtt Tensorflow Kafka Realtime Iot Machine Learning Training Inference263 ⭐
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
Kstreams Des Demo20 ⭐
Kafka Streams demo project containing Derivative Events, the Processor Api and Wall-clock examples
Azkarra Streams168 ⭐
🚀 Azkarra is a lightweight java framework to make it easy to develop, deploy and manage cloud-native streaming microservices based on Apache Kafka Streams.
Optimizing Public Transportation20 ⭐
A real-time event pipeline around Kafka Ecosystem for Chicago Transit Authority.
Workshop Codecon Kafka11 ⭐
Exemplos do workshop realizado na codecon.dev sobre arquitetura event-driven com Apache Kafka.
SigNoz is an open-source APM. It helps developers monitor their applications & troubleshoot problems, an open-source alternative to DataDog, NewRelic, etc. 🔥 🖥. 👉 Open source Application Performance Monitoring (APM) & Observability tool
Scalatest Embedded Kafka291 ⭐
A library that provides an in-memory Kafka instance to run your tests against.
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.
Nodefluent Kafka Streams715 ⭐
equivalent to kafka-streams :octopus: for nodejs :sparkles::turtle::rocket::sparkles:
一个基于Softflowd，Kafka，Spark Streaming，Elk，Django开发的网络数据流监控分析后台， 支持Netflow V9与Netflow V5。可以对进入和流出的流量进行异常分析并执行自动化漏洞修复。