kafka-streams | Topic | Ecosyste.ms: Repos

Topic: "kafka-streams"

provectus/kafka-ui

Open-Source Web UI for Apache Kafka Management

Language: Java - Size: 29 MB - Last synced at: about 9 hours ago - Pushed at: 10 months ago - Stars: 10,729 - Forks: 1,271

robinhood/faust

Python Stream Processing

Language: Python - Size: 8.3 MB - Last synced at: 19 days ago - Pushed at: 10 months ago - Stars: 6,787 - Forks: 534

strimzi/strimzi-kafka-operator

Apache Kafka® running on Kubernetes

Language: Java - Size: 91.8 MB - Last synced at: 5 days ago - Pushed at: 6 days ago - Stars: 5,216 - Forks: 1,362

memgraph/memgraph

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

Language: C++ - Size: 42.6 MB - Last synced at: about 11 hours ago - Pushed at: about 12 hours ago - Stars: 2,878 - Forks: 154

reugn/go-streams

A lightweight stream processing library for Go

Language: Go - Size: 587 KB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 2,028 - Forks: 164

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/

Language: Shell - Size: 210 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1,531 - Forks: 902

SeldonIO/seldon-server

Machine Learning Platform and Recommendation Engine built on Kubernetes

Language: Java - Size: 3.51 MB - Last synced at: 4 days ago - Pushed at: about 5 years ago - Stars: 1,472 - Forks: 299

kafbat/kafka-ui

Open-Source Web UI for managing Apache Kafka clusters

Language: Java - Size: 34.7 MB - Last synced at: 5 days ago - Pushed at: 7 days ago - Stars: 1,054 - Forks: 138

speedb-io/speedb

A RocksDB compliant high performance scalable embedded key-value store

Language: C++ - Size: 144 MB - Last synced at: 12 days ago - Pushed at: 11 months ago - Stars: 973 - Forks: 76

danielealbano/cachegrand

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

Language: C - Size: 9.13 MB - Last synced at: 9 months ago - Pushed at: 9 months ago - Stars: 969 - Forks: 34

nodefluent/kafka-streams

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

Language: TypeScript - Size: 4.14 MB - Last synced at: 4 days ago - Pushed at: about 2 years ago - Stars: 835 - Forks: 111

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.

Language: Java - Size: 51.5 MB - Last synced at: 10 months ago - Pushed at: over 1 year ago - Stars: 834 - Forks: 304

simplesteph/kafka-streams-course

Learn Kafka Streams with several examples!

Language: Java - Size: 56.6 KB - Last synced at: over 1 year ago - Pushed at: almost 3 years ago - Stars: 740 - Forks: 413

infoslack/awesome-kafka

A list about Apache Kafka

Size: 96.7 KB - Last synced at: 11 days ago - Pushed at: 2 months ago - Stars: 581 - Forks: 163

hypertrace/hypertrace

An open source distributed tracing & observability platform

Language: Shell - Size: 523 KB - Last synced at: 7 months ago - Pushed at: 7 months ago - Stars: 516 - Forks: 32

LGouellec/streamiz

.NET Stream Processing Library for Apache Kafka 🚀

Language: C# - Size: 12.4 MB - Last synced at: 5 days ago - Pushed at: about 2 months ago - Stars: 495 - Forks: 79

gojek/ziggurat

A stream processing framework to build stateless applications on Kafka

Language: Clojure - Size: 1.48 MB - Last synced at: about 11 hours ago - Pushed at: 5 months ago - Stars: 402 - Forks: 64

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

Language: Java - Size: 170 MB - Last synced at: 13 days ago - Pushed at: 3 months ago - Stars: 385 - Forks: 48

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

Language: Jupyter Notebook - Size: 24.9 MB - Last synced at: over 1 year ago - Pushed at: over 4 years ago - Stars: 373 - Forks: 138

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

Language: Java - Size: 487 KB - Last synced at: 19 days ago - Pushed at: 19 days ago - Stars: 331 - Forks: 165

fhussonnois/kafkastreams-cep

Complex Event Processing on top of Kafka Streams

Language: Java - Size: 434 KB - Last synced at: about 1 month ago - Pushed at: over 1 year ago - Stars: 311 - Forks: 62

wintoncode/winton-kafka-streams

A Python implementation of Apache Kafka Streams

Language: Python - Size: 272 KB - Last synced at: about 1 month ago - Pushed at: over 6 years ago - Stars: 311 - Forks: 55

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.

Language: C# - Size: 401 MB - Last synced at: 7 days ago - Pushed at: about 1 month ago - Stars: 302 - Forks: 91

manub/scalatest-embedded-kafka

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

Language: Scala - Size: 322 KB - Last synced at: about 1 month ago - Pushed at: over 5 years ago - Stars: 293 - Forks: 83

monksy/awesome-kafka

A collection of kafka-resources

Size: 101 KB - Last synced at: 4 days ago - Pushed at: about 2 months ago - Stars: 213 - Forks: 44

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

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

Language: Scala - Size: 79.8 MB - Last synced at: 10 days ago - Pushed at: almost 6 years ago - Stars: 212 - Forks: 71

juicycleff/nestjs-event-store

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

Language: TypeScript - Size: 550 KB - Last synced at: 3 days ago - Pushed at: over 2 years ago - Stars: 201 - Forks: 29

lightbend/kafka-streams-scala 📦

Thin Scala wrapper around Kafka Streams Java API

Language: Scala - Size: 249 KB - Last synced at: 1 day ago - Pushed at: almost 2 years ago - Stars: 190 - Forks: 51

jpzk/mockedstreams

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

Language: Scala - Size: 20 MB - Last synced at: 9 days ago - Pushed at: over 4 years ago - Stars: 186 - Forks: 24

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.

Language: HTML - Size: 18.8 MB - Last synced at: 1 day ago - Pushed at: over 2 years ago - Stars: 182 - Forks: 23

framiere/a-kafka-story

Kafka ecosystem ... but step by step!

Language: Java - Size: 8.25 MB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 166 - Forks: 67

hortonworks/streamline

StreamLine - Streaming Analytics

Language: Java - Size: 66 MB - Last synced at: about 2 months ago - Pushed at: over 1 year ago - Stars: 164 - Forks: 96

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.

Language: Java - Size: 5.25 MB - Last synced at: 30 days ago - Pushed at: almost 5 years ago - Stars: 164 - Forks: 163

ppatierno/formula1-telemetry-kafka

Language: Java - Size: 15.2 MB - Last synced at: about 1 month ago - Pushed at: 4 months ago - Stars: 153 - Forks: 28

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

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

Language: Java - Size: 394 KB - Last synced at: over 1 year ago - Pushed at: almost 2 years ago - Stars: 140 - Forks: 44

DaveWM/willa

A Clojure DSL for Kafka Streams

Language: Clojure - Size: 116 KB - Last synced at: 5 days ago - Pushed at: over 2 years ago - Stars: 138 - Forks: 13

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.

Language: Java - Size: 3.34 MB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 135 - Forks: 47

michelin/kstreamplify

Swiftly build and enhance your Kafka Streams applications.

Language: Java - Size: 3.63 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 129 - Forks: 23

opentracing-contrib/java-kafka-client

OpenTracing Instrumentation for Apache Kafka Client

Language: Java - Size: 349 KB - Last synced at: about 1 month ago - Pushed at: over 1 year ago - Stars: 127 - Forks: 64

hellosatish/microservice-patterns

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

Language: Java - Size: 3.41 MB - Last synced at: 6 months ago - Pushed at: over 4 years ago - Stars: 116 - Forks: 119

mmolimar/kukulcan

A REPL for Apache Kafka

Language: Scala - Size: 2.74 MB - Last synced at: 5 months ago - Pushed at: about 4 years ago - Stars: 115 - Forks: 7

ivangfr/springboot-kafka-connect-jdbc-streams

Project goal: Explore Kafka, Kafka Connect, and Kafka Streams. Components: store-api: Inserts/updates MySQL records. Source Connectors: Monitor MySQL changes, push messages to Kafka. Sink Connectors: Listen to Kafka, insert/update Elasticsearch docs. store-streams: Listens to Kafka, processes with Kafka Streams, pushes new messages to Kafka.

Language: Java - Size: 283 MB - Last synced at: 19 days ago - Pushed at: 19 days ago - Stars: 113 - Forks: 72

bitbouncer/kspp

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

Language: C++ - Size: 3.5 MB - Last synced at: over 1 year ago - Pushed at: over 2 years ago - Stars: 112 - Forks: 24

Hurence/logisland

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.

Language: Java - Size: 120 MB - Last synced at: about 1 month ago - Pushed at: over 1 year ago - Stars: 109 - Forks: 29

Angular2Guy/AngularAndSpring

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

Language: Java - Size: 6.05 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 106 - Forks: 46

bobby/kafka-streams-clojure

Clojure transducers interface to Kafka Streams

Language: Clojure - Size: 18.6 KB - Last synced at: 10 days ago - Pushed at: over 7 years ago - Stars: 102 - Forks: 9

danielsobrado/CCDAK-Exam-Questions

Confluent Kafka questions to practice for CCDAK

Size: 335 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 90 - Forks: 32

bakdata/fluent-kafka-streams-tests

Fluent Kafka Streams Test with Java

Language: Java - Size: 600 KB - Last synced at: about 1 month ago - Pushed at: about 2 months ago - Stars: 89 - Forks: 16

perkss/clojure-kafka-examples

Clojure examples for Kafka and Kafka Streams (JAVA Interop)

Language: Clojure - Size: 115 KB - Last synced at: about 1 month ago - Pushed at: 8 months ago - Stars: 83 - Forks: 11

hifly81/kafka-examples

Practical examples with Apache Kafka®

Language: Java - Size: 120 MB - Last synced at: 19 days ago - Pushed at: 19 days ago - Stars: 76 - Forks: 15

jaceklaskowski/mastering-kafka-streams-book

No longer maintained and soon to be deleted

Size: 2.49 MB - Last synced at: 3 months ago - Pushed at: over 5 years ago - Stars: 76 - Forks: 36

hdimitrieski/e-shop

Sample Spring Cloud microservices e-shop.

Language: Java - Size: 11.7 MB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 74 - Forks: 44

typestreamio/typestream

Open Source streaming platform. Write and run typed data pipelines with a minimal, familiar syntax.

Language: Kotlin - Size: 8.05 MB - Last synced at: 1 day ago - Pushed at: 2 months ago - Stars: 72 - Forks: 5

oslabs-beta/ksqlSuite

Node.js client for ksqlDB

Language: JavaScript - Size: 5.69 MB - Last synced at: 12 days ago - Pushed at: almost 2 years ago - Stars: 71 - Forks: 4

lightbend/kafka-streams-query 📦

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

Language: Scala - Size: 102 KB - Last synced at: almost 2 years ago - Pushed at: about 2 years ago - Stars: 69 - Forks: 22

rmoff/ksqldb-go

A Golang client for ksqlDB

Language: Go - Size: 6.83 MB - Last synced at: 5 months ago - Pushed at: over 3 years ago - Stars: 69 - Forks: 11

pathwaycom/pathway-benchmarks

Benchmarks for data processing systems: Pathway, Spark, Flink, Kafka Streams

Language: Python - Size: 4.7 MB - Last synced at: about 1 month ago - Pushed at: about 2 months ago - Stars: 68 - Forks: 4

ardlema/kafka-streams-workshop

Language: Scala - Size: 66.4 KB - Last synced at: about 1 year ago - Pushed at: over 6 years ago - Stars: 67 - Forks: 5

kattlo/kattlo-cli 📦

Kattlo CLI Project

Language: Java - Size: 1.16 MB - Last synced at: 4 months ago - Pushed at: over 3 years ago - Stars: 66 - Forks: 4

djarza/football-events

Event-Driven microservices with Kafka Streams

Language: Java - Size: 2.81 MB - Last synced at: about 2 months ago - Pushed at: almost 4 years ago - Stars: 64 - Forks: 26

niqdev/kafka-scala-examples

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

Language: Scala - Size: 11.3 MB - Last synced at: about 1 month ago - Pushed at: 9 months ago - Stars: 63 - Forks: 15

jaceklaskowski/kafka-workshop

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

Language: JavaScript - Size: 9.6 MB - Last synced at: about 1 month ago - Pushed at: 11 months ago - Stars: 62 - Forks: 29

bakdata/kafka-large-message-serde

A Kafka Serde that reads and writes records from and to Blob storage (S3, Azure, Google) transparently.

Language: Java - Size: 499 KB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 59 - Forks: 9

azhur/kafka-serde-scala

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

Language: Scala - Size: 285 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 57 - Forks: 9

perkss/kotlin-kafka-and-kafka-streams-examples

Kafka with KafkaReactor and Kafka Streams Examples in Kotlin

Language: Kotlin - Size: 447 KB - Last synced at: 30 days ago - Pushed at: 5 months ago - Stars: 54 - Forks: 12

matsumana/tsujun 📦

Yet another Web UI for KSQL

Language: Kotlin - Size: 248 KB - Last synced at: 9 days ago - Pushed at: almost 7 years ago - Stars: 53 - Forks: 9

QuickSign/kafka-encryption

Kafka End to End Encryption

Language: Java - Size: 199 KB - Last synced at: 10 months ago - Pushed at: over 1 year ago - Stars: 52 - Forks: 10

sanjayvacharya/sleeplessinslc

Demo code from

Language: Java - Size: 4.58 MB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 52 - Forks: 65

TechPrimers/kafka-streams-microservices-example

End to End project for Kafka Streams using Spring Cloud Kafka streams

Language: Java - Size: 174 KB - Last synced at: 27 days ago - Pushed at: about 4 years ago - Stars: 50 - Forks: 67

jpzk/twitterstream

Twitter Streaming API Example with Kafka Streams in Scala

Language: Scala - Size: 22.5 KB - Last synced at: about 2 years ago - Pushed at: over 8 years ago - Stars: 49 - Forks: 13

rohit-mehra/eye_of_sauron

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

Language: Python - Size: 134 MB - Last synced at: about 2 years ago - Pushed at: almost 5 years ago - Stars: 48 - Forks: 26

aseigneurin/kafka-streams-scala

Thin Scala wrapper for the Kafka Streams API

Language: Scala - Size: 39.1 KB - Last synced at: almost 2 years ago - Pushed at: about 7 years ago - Stars: 47 - Forks: 11

typesafehub/fdp-modelserver

An umbrella project for multiple implementations of model serving

Language: Scala - Size: 163 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 46 - Forks: 20

masesgroup/KNet

KNet is a comprehensive .NET suite for Apache Kafka™ providing all features: Producer, Consumer, Admin, Streams, Connect, backends (ZooKeeper and Kafka)

Language: C# - Size: 138 MB - Last synced at: 2 days ago - Pushed at: 10 days ago - Stars: 45 - Forks: 6

bakdata/streams-explorer

Explore Apache Kafka data pipelines in Kubernetes.

Language: Python - Size: 3.63 MB - Last synced at: about 1 month ago - Pushed at: 3 months ago - Stars: 45 - Forks: 5

andreas-schroeder/redisks

Redis Kafka Streams State Store

Language: Scala - Size: 116 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 45 - Forks: 5

Klarrio/open-stream-processing-benchmark

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

Language: Jupyter Notebook - Size: 5.97 MB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 45 - Forks: 12

srigumm/eCupcakesFactoryOnContainers

"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.

Language: JavaScript - Size: 7.49 MB - Last synced at: over 1 year ago - Pushed at: over 4 years ago - Stars: 44 - Forks: 29