734 Open source projects that are alternatives of or similar to Storm Dynamic Spout

Kafka Tutorials microsite

Wirbelsturm is a Vagrant and Puppet based tool to perform 1-click local and remote deployments, with a focus on big data tech like Kafka.

A list about Apache Kafka

Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.

StreamLine - Streaming Analytics

This toolkit is focused on interacting with popular messaging systems such as Kafka, JMS, XMS, and MQTT. After release v5.4.2 the complete toolkit will be deprecated. See the README.md file for hints to alternative toolkits.

light, fast, scalable, streaming microservices made easy

Framework for Apache Kafka based Ruby and Rails applications development.

A REPL for Apache Kafka

WaterDrop is a standalone Karafka component library for generating Kafka messages

Apache Kafka on Docker

Distributed Stream and Batch Processing

Samsara is a real-time analytics platform

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

Apache Kafka Web UI for exploring messages, consumers, configurations and more with a focus on a good UI & UX.

Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.

Azure Event Hubs for Apache Kafka Ecosystems

Schema Registry

Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.

Open-Source Web GUI for Apache Kafka Management

Fancy stream processing made operationally mundane

Kafka Connect HDFS connector

Modern C++ Apache Kafka client library (wrapper for librdkafka)

Kasper is a lightweight library for processing Kafka topics.

Kafka command line tool that likes JSON

Dumps state of Storm Kafka consumers

大数据入门指南 ⭐

Spring Boot 2.x code examples

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.

Neo4j Kafka Integrations, Docs =>

Golang Kafka consumer and producer example

Source code for the Kafka Streams in Action Book

关于kafka的一些相关使用示例代码。

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

Building event-driven applications the easy way in Go.

Kattlo CLI Project

推荐项目（实时推荐和离线推荐）

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

Kafka 한국 사용자 모임에서 운영하는 meetup repository

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

Streaming System 相关的论文读物

docker-compose.yml files for cp-all-in-one , cp-all-in-one-community, cp-all-in-one-cloud

Command Line Tool for managing Apache Kafka

an online learning algorithm library for Storm

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

The Apache Kafka C/C++ library

A lightweight stream processing library for Go

🚀 Web GUI for Kafka Cluster Management

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

Kafka-based Job Queue for Python

Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.

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

The database purpose-built for stream processing applications.

Ship changes in Postgres 🐘 to Kafka 📖

Kafka client for functional streams for scala (fs2)

Oryx 2: Lambda architecture on Apache Spark, Apache Kafka for real-time large scale machine learning

Code for Agile Data Science 2.0, O'Reilly 2017, Second Edition

Python Stream Processing

Files needed to try out KSQL Recipes for yourself