Topic: kafka-streams Goto Github

👇 Here are 1010 public repositories matching this topic...

airyhq / airy
kafka-streams,💬 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
Organization: airyhq
Home Page: https://airy.co/docs/core
airy ingestion-platform nlp bot natural-language-processing bots nlu conversational-ai conversational-bots opensource

angular2guy / angularandspring
kafka-streams,This is an example application to show howto use Spring Boot 3, Angular 17, 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.
User: angular2guy
Home Page: https://angular2guy.wordpress.com/
angular angular-cli angular-components angular17 archunit clean-architecture helm-chart java kafka kafka-streams kubernetes mongodb spring-actuator spring-boot spring-webflux springboot3 structurizr typescript

bakdata / fluent-kafka-streams-tests
kafka-streams,Fluent Kafka Streams Test with Java
Organization: bakdata
Home Page: https://medium.com/bakdata/fluent-kafka-streams-tests-e641785171ec
kafka-streams testing test-framework testing-framework avro java

bitbouncer / kspp
kafka-streams,A high performance/ real-time C++ Kafka streams framework (C++17)
Organization: bitbouncer
kafka kafka-streams librdkafka cpp cpp17 cpp17-library stream-processing kafka-connect

bobby / kafka-streams-clojure
kafka-streams,Clojure transducers interface to Kafka Streams
User: bobby
kafka kafka-streams clojure transducers

confluentinc / demo-scene
kafka-streams,👾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/
Organization: confluentinc
Home Page: https://developer.confluent.io
kafka ksql elasticsearch syslog mysql debezium kafka-streams kafka-connect ksqldb demo

confluentinc / kafka-tutorials
kafka-streams,Tutorials and Recipes for Apache Kafka
Organization: confluentinc
Home Page: https://developer.confluent.io/tutorials
kafka-tutorials ksqldb kafka kafka-streams apache-kafka stream-processing

confluentinc / learn-kafka-courses
kafka-streams,Learn the basics of Apache Kafka® from leaders in the Kafka community with these video courses covering the Kafka ecosystem and hands-on exercises.
Organization: confluentinc
Home Page: https://developer.confluent.io/
apache-kafka kafka kafka-streams data-pipelines data-pipeline ksqldb stream-processing

danielealbano / cachegrand
kafka-streams,cachegrand - a modern data ingestion, processing and serving platform built for today's hardware
User: danielealbano
memcache redis caching linux high-performance io-uring redis-server key-value key-value-store low-latency

davewm / willa
kafka-streams,A Clojure DSL for Kafka Streams
User: davewm
clojure kafka kafka-streams

fhussonnois / kafkastreams-cep
kafka-streams,Complex Event Processing on top of Kafka Streams
User: fhussonnois
kafka-streams kafka cep complex-event-processing

framiere / a-kafka-story
kafka-streams,Kafka ecosystem ... but step by step!
User: framiere
kafka kafka-broker zookeeper cdc debezium ksql kafka-streams

gojek / ziggurat
kafka-streams,A stream processing framework to build stateless applications on Kafka
Organization: gojek
kafka-streams clojure framework

hellosatish / microservice-patterns
kafka-streams,Code to share the knowledge I gained while designing and implementing micro services
User: hellosatish
microservices-architecture microservices swagger-ui kafka-streams event-driven spring-boot golang service-discovery security owasp-top-10 api-sec

hortonworks / streamline
kafka-streams,StreamLine - Streaming Analytics
Organization: hortonworks
streaming real-time storm spark-streaming kafka kafka-streams flink

hurence / logisland
kafka-streams,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.
Organization: hurence
Home Page: https://logisland.github.io
big-data stream-processing kafka spark analytics complex-event-processing pattern-recognition kafka-streams elasticsearch cassandra

hypertrace / hypertrace
kafka-streams,An open source distributed tracing & observability platform
Organization: hypertrace
Home Page: https://www.hypertrace.org/
observability monitoring kubernetes distributed-tracing cloud-native tracing opentelemetry application-monitoring java kafka

infoslack / awesome-kafka
kafka-streams,A list about Apache Kafka
User: infoslack
kafka streaming-data data-pipeline stream-processing apache-kafka apache-spark kafka-streams infrastructure data-processing

ivangfr / springboot-kafka-connect-jdbc-streams
kafka-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.
User: ivangfr
spring-boot kafka kafka-connect kafka-streams mysql elasticsearch spring-cloud-stream schema-registry avro json

jpzk / mockedstreams
kafka-streams,Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
User: jpzk
kafka-streams mocked-streams kafka scala testing unit-testing topology

juicycleff / nestjs-event-store
kafka-streams,NestJS CQRS module for EventStore.org. It requires @nestjs/cqrs
User: juicycleff
Home Page: https://xraph.com
cqrs-pattern cqrs event-sourcing event-store event-storage nestjs nest library nats-streaming nats

kafbat / kafka-ui
kafka-streams,Open-Source Web UI for managing Apache Kafka clusters
Organization: kafbat
Home Page: http://ui.docs.kafbat.io
apache-kafka big-data cluster-management event-streaming foss hacktoberfest kafka kafka-brokers kafka-client kafka-cluster kafka-connect kafka-manager kafka-producer kafka-streams kafka-ui opensource streaming-data streams web-ui

kaiwaehner / hivemq-mqtt-tensorflow-kafka-realtime-iot-machine-learning-training-inference
kafka-streams,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
User: kaiwaehner
kafka hivemq mqtt kafka-streams kafka-connect ksql tensorflow grpc java python

kaiwaehner / kafka-streams-machine-learning-examples
kafka-streams,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.
User: kaiwaehner
kafka kafka-streams kafka-client machine-learning deep-learning open-source h2o h2oai tensorflow deeplearning4j keras keras-tensorflow dl4j ksql java python

kaiwaehner / tensorflow-serving-java-grpc-kafka-streams
kafka-streams,Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response
User: kaiwaehner
apache kafka kafka-streams apache-kafka confluent grpc grpc-java tensorflow tensorflow-serving deeplearning

learningjournal / kafka-streams-real-time-stream-processing
kafka-streams,This is the central repository for all materials related to Kafka Streams : Real-time Stream Processing! Book by Prashant Pandey.
User: learningjournal
kafka-streams stream-processing apache-kafka real-time-stream-processing java-8 kafka-client kafka-producer kafka streams messaging-system

lgouellec / kafka-streams-dotnet
kafka-streams,.NET Stream Processing Library for Apache Kafka 🚀
User: lgouellec
Home Page: https://lgouellec.github.io/kafka-streams-dotnet/
kafka-streams-dotnet kafka-streams kafka-streams-net kafka event-streaming streamiz

lightbend / kafka-streams-scala
kafka-streams,Thin Scala wrapper around Kafka Streams Java API
Organization: lightbend
kafka-streams kafka scala akka-http

lightbend / kafka-with-akka-streams-kafka-streams-tutorial
kafka-streams,Code samples for the Lightbend tutorial on writing microservices with Akka Streams, Kafka Streams, and Kafka
Organization: lightbend
akka kafka-streams model-serving

manub / scalatest-embedded-kafka
kafka-streams,A library that provides an in-memory Kafka instance to run your tests against.
User: manub
scala kafka kafka-streams scalatest

memgraph / memgraph
kafka-streams,Open-source graph database, tuned for dynamic analytics environments. Easy to adopt, scale and own.
Organization: memgraph
Home Page: https://memgraph.com
graph-algorithms graph-database graph-analysis stream-processing streaming-data kafka-streams kafka cypher graph nosql

michelin / kstreamplify
kafka-streams,Kstreamplify is a Java library that brings new features on top of Kafka Streams.
Organization: michelin
kafka kafka-streams spring-boot java topology

microsoft / data-accelerator
kafka-streams,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.
Organization: microsoft
spark spark-streaming spark-sql sparksql streaming-data streaming servicefabric nodejs docker hdinsight cosmosdb react azure apache-spark iothub eventhub big-data iot kafka kafka-streams

mmolimar / kukulcan
kafka-streams,A REPL for Apache Kafka
User: mmolimar
kafka apache-kafka repl shell kafka-repl kafka-shell ammonite kafka-connect kafka-streams kafka-admin kafka-consumer kafka-producer scala java python

monksy / awesome-kafka
kafka-streams,A collection of kafka-resources
User: monksy
kafka kafka-streams awesome awesome-list awesome-lists

nodefluent / kafka-streams
kafka-streams,equivalent to kafka-streams :octopus: for nodejs :sparkles::turtle::rocket::sparkles:
Organization: nodefluent
Home Page: https://nodefluent.github.io/kafka-streams/
big-data kafka kafka-streams node nodejs stream-processing streams

opentracing-contrib / java-kafka-client
kafka-streams,OpenTracing Instrumentation for Apache Kafka Client
Organization: opentracing-contrib
opentracing java kafka kafka-client kafka-streams spring-kafka

perkss / clojure-kafka-examples
kafka-streams,Clojure examples for Kafka and Kafka Streams (JAVA Interop)
User: perkss
Home Page: https://perkss.github.io/#/clojure/KafkaClojure#text-body
clojure kafka kafka-streams functional-programming avro-kafka java kafka-topic testcontainers

piomin / sample-spring-kafka-microservices
kafka-streams,Example microservices showing how to use Kafka and Kafka Streams with Spring Boot on the example of distributed transactions implementations with the SAGA pattern
User: piomin
Home Page: https://piotrminkowski.com/
kafka kafka-streams spring-boot spring-kafka

ppatierno / formula1-telemetry-kafka
kafka-streams,
User: ppatierno
kafka kafka-influxdb udp-kafka telemetry-data telemetry-events grafana influxdb kafka-streams formula1 apache-camel

provectus / kafka-ui
kafka-streams,Open-Source Web UI for Apache Kafka Management
Organization: provectus
kafka-ui kafka-brokers kafka kafka-streams kafka-client opensource kafka-connect kafka-producer streams big-data

reugn / go-streams
kafka-streams,A lightweight stream processing library for Go
User: reugn
Home Page: https://pkg.go.dev/github.com/reugn/go-streams
stream-processing pipeline etl kafka data-stream kafka-streams streams redis pulsar data-pipeline

robinhood / faust
kafka-streams,Python Stream Processing
Organization: robinhood
kafka-streams kafka python asyncio distributed-systems stream-processing

seldonio / seldon-server
kafka-streams,Machine Learning Platform and Recommendation Engine built on Kubernetes
Organization: seldonio
Home Page: https://www.seldon.io/
machine-learning deep-learning deployment kubernetes docker microservices spark kafka kafka-streams tensorflow

simplesteph / kafka-streams-course
kafka-streams,Learn Kafka Streams with several examples!
User: simplesteph
Home Page: https://www.udemy.com/kafka-streams/?couponCode=GITHUB
kafka kafka-streams learning udemy

speedb-io / speedb
kafka-streams,A RocksDB compliant high performance scalable embedded key-value store
Organization: speedb-io
Home Page: https://www.speedb.io/
key-value-store kvs storage-engine speedb embedded performance rocksdb scale kafka-streams

streamthoughts / azkarra-streams
kafka-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.
Organization: streamthoughts
Home Page: https://www.azkarrastreams.io/
kafka kafka-streams micro-framework data webui java interactive-queries apache-kafka azkarra-streams cloud-native microservices

strimzi / strimzi-kafka-operator
kafka-streams,Apache Kafka® running on Kubernetes
Organization: strimzi
Home Page: https://strimzi.io/
kafka kubernetes openshift docker messaging enmasse kafka-connect kafka-streams data-streaming data-stream

wintoncode / winton-kafka-streams
kafka-streams,A Python implementation of Apache Kafka Streams
Organization: wintoncode
kafka-streams streaming-api librdkafka python

zakariamaaraki / remotecodecompiler
kafka-streams,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.
User: zakariamaaraki
coding-interviews competitive-programming docker grpc java kafka kafka-streams rabbitmq serverless spring-boot stream-processing