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

Confluent REST Proxy for Kafka

Simplifying Kafka for ruby apps

Syslog Collector written in Go, streams to Kafka 0.8

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.

**Unofficial / Community** Kafka Connect MongoDB Sink Connector - Find the official MongoDB Kafka Connector here: https://www.mongodb.com/kafka-connector

Secor is a service implementing Kafka log persistence

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

Node.js bindings for librdkafka

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

Extended datasource support for Spark/Hadoop on Aliyun E-MapReduce.

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

Community driven, reusable components for distributed apps

High throughput asynchronous task processing on Apache Kafka

Metronome is a distributed and fault-tolerant event scheduler

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

Avro SerDe for Apache Spark structured APIs.

Kafka web UI

Python Stream Processing. A Faust fork

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

Neo4j Kafka Integrations, Docs =>

[https://www.sofineday.com], golang项目开发脚手架,集成最佳实践(gin+gorm+go-redis+mongo+cors+jwt+json日志库zap(支持日志收集到kafka或mongo)+消息队列kafka+微信支付宝支付gopay+api加密+api反向代理+go modules依赖管理+headless爬虫chromedp+makefile+二进制压缩+livereload热加载)

Azure Event Hubs for Apache Kafka Ecosystems

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

PG数据同步工具（Java实现）

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

Production-ready, stable Kafka client for PHP

Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.

Modern and performant Kafka client library for Ruby based on librdkafka

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

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

mq transaction, tcc, eventually consistency. tx life cycle: all listeners handled, if necessary, produce next message

Apache Kafka load testing "...basically a cloth bag filled with small jagged pieces of scrap iron"

Collection of Kubernetes Operators built with KUDO.

Load data from Kafka to any data warehouse

Apache Spark and Apache Kafka integration example

a command-line Protobuf parser with Kafka support and JSON output

Kafka GUI for Apache Kafka to manage topics, topics data, consumers group, schema registry, connect and more...

Learn the Confluent Schema Registry & REST Proxy

docker compose files to create a fully working kafka stack

Java SDK for CloudEvents

🥚 Netty实践学习案例，见微知著！带着你的心，跟着教程。我相信你行欧。

My own version of r/place, done in a weekend

Kafka Docker for development. Kafka, Zookeeper, Schema Registry, Kafka-Connect, Landoop Tools, 20+ connectors

PHP Kafka client is used in PHP-FPM and Swoole. PHP Kafka client supports 50 APIs, which might be one that supports the most message types ever.

KafkaFlow is a .NET framework to consume and produce Kafka messages with multi-threading support. It's very simple to use and very extendable. You just need to install, configure, start/stop the bus with your app and create a middleware/handler to process the messages.

Self-contained examples of Apache Spark streaming integrated with Apache Kafka.

A easy and high-performance monitoring system, for comprehensive monitoring and management of kafka cluster.

CMAK is a tool for managing Apache Kafka clusters

The AsyncAPI specification allows you to create machine-readable definitions of your asynchronous APIs.

A kafka command line browser

Kafka Connect Tooling

A search framework and multi-tenant search platform based on java, kafka, kafka connect, elasticsearch

❤for real-time DataOps - where the application and data fabric blends - Lenses

Distributed Java game server, including login, gateway, game demo

Scala library to eliminate boilerplate

This repo contains my notes on working with Go and computer systems.

支持mysql、MongoDB数据变更订阅分发

Schema Registry

基于 Springboot + Redis + Kafka 的秒杀系统，乐观锁 + 缓存 + 限流 + 异步，TPS 从 500 优化到 3000