479 Open source projects that are alternatives of or similar to Kafka Streams Scala

A resilient and scalable shopping cart system designed using Event Sourcing (ES) and Command Query Responsibility Segregation (CQRS)

StreamLine - Streaming Analytics

An umbrella project for multiple implementations of model serving

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

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

Python Stream Processing

Kafka consumer lag-checking application for monitoring, written in Scala and Akka HTTP; a wrap around the Kafka consumer group command. Integrations with Cloudwatch and Datadog. Authentication recently added

Apache Kafka running on Kubernetes

.NET Stream Processing Library for Apache Kafka 🚀

[DEPRECATED] Docker images for Confluent Platform.

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

A REPL for Apache Kafka

Open-Source Web GUI for Apache Kafka Management

A list about Apache Kafka

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

Kattlo CLI Project

OpenTracing Instrumentation for Apache Kafka Client

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.

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

A lightweight stream processing library for Go

Learn Kafka Streams with several examples!

Kafka ecosystem ... but step by step!

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.

A Clojure DSL for 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.

Demo applications and code examples for Confluent Platform and Apache Kafka

A collection of kafka-resources

Complex Event Processing on top of 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

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

equivalent to kafka-streams 🐙 for nodejs ✨🐢🚀✨

👾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/

Framework for building distributed microserviceies in scala with akka-streams and kafka

Yet another Web UI for KSQL

Machine Learning Platform and Recommendation Engine built on Kubernetes

Kafka Tutorials microsite

MongoDB Kafka Connector

Simplifying Kafka for ruby apps

大数据分析可视化实践

DC/OS SDK is a collection of tools, libraries, and documentation for easy integration of technologies such as Kafka, Cassandra, HDFS, Spark, and TensorFlow with DC/OS.

Lightweight api management on top of a modern http reverse proxy

Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar

An Hexagonal Architecture with DDD + Aggregates + Event Sourcing using .NET Core, Kafka e MongoDB (Blog Engine)

A complete example of a big data application using : Kubernetes (kops/aws), Apache Spark SQL/Streaming/MLib, Apache Flink, Scala, Python, Apache Kafka, Apache Hbase, Apache Parquet, Apache Avro, Apache Storm, Twitter Api, MongoDB, NodeJS, Angular, GraphQL

本人的RabbitMQ和Kafka详细笔记以及示例代码

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

High throughput asynchronous task processing on Apache Kafka

OpenMessaging Benchmark Framework

《Kafka技术内幕》代码

Confluent's Apache Kafka .NET client

我,请始皇[打钱]是一个前后端分离的工具人系统，项目采用 SpringBoot+Go+Vue 开发，项目加入常见的企业级应用所涉及到的技术点，例如 Redis、RabbitMQ 等(主要是多用用工具多踩踩坑)。

Kafka web UI

Laravel Enqueue message queue extension. Supports AMQP, Amazon SQS, Kafka, Google PubSub, Redis, STOMP, Gearman, Beanstalk and others

Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.

Write your Spark data to Kafka seamlessly

Apollo graphql subscriptions over Kafka protocol

Redpanda is the real-time engine for modern apps. Kafka API Compatible; 10x faster 🚀 See more at vectorized.io/redpanda

light, fast, scalable, streaming microservices made easy

Kafka Connect suite of connectors for Cloud storage (Amazon S3)

Proxy connections to Kafka cluster. Connect through SOCKS Proxy, HTTP Proxy or to cluster running in Kubernetes.