salesforce / storm-dynamic-spout
A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.
☆40Updated 3 years ago
Alternatives and similar repositories for storm-dynamic-spout:
Users that are interested in storm-dynamic-spout are comparing it to the libraries listed below
- A set of tools to ease working with Zookeeper and Kafka.☆23Updated 9 years ago
- SamzaSQL: Streaming SQL implementation on top of Apache Samza and Apache Kafka☆29Updated 8 years ago
- Cascading on Apache Flink®☆54Updated 11 months ago
- Hadoop Data Integration with various databases, ftp servers, salesforce. Incremental update, dedup, append, merge your data on Hadoop.☆91Updated 11 years ago
- ☆76Updated 8 years ago
- NO LONGER MAINTAINED: Database.com SDK for Java☆47Updated 6 years ago
- Spooker is a dynamic framework for processing high volume data streams via processing pipelines☆29Updated 9 years ago
- The Scala Rule Engine☆42Updated 3 years ago
- Framework for creating and deploying Apache Storm Topologies☆46Updated 9 years ago
- Common utilities for Apache Kafka☆36Updated last year
- Hadoop MapReduce tool to convert Avro data files to Parquet format.☆34Updated 11 years ago
- Docker containers for Druid nodes☆27Updated 8 years ago
- A High Performance Cluster Consumer for Kafka that creates Avro (boom) files in Hadoop in time based directory paths☆42Updated 8 years ago
- Apache Amaterasu☆56Updated 5 years ago
- A library for strong, schema based conversion between 'natural' JSON documents and Avro☆18Updated 10 months ago
- This project provides utilities and wrappers around ZooKeeper☆64Updated 11 years ago
- Experiments in Streaming☆60Updated 8 years ago
- Metrics produced to Kafka and consumers for monitoring them☆100Updated 10 years ago
- Lucene based indexing in Cassandra☆61Updated 8 years ago
- A JMM Cookbook for Java Developers(as opposed to a cookbook for Compiler Writers)☆12Updated 10 years ago
- Library to use Kafka as a spout within Storm☆43Updated 13 years ago
- Dead-simple vertical partitioning, compression, appends, and consolidation of data on a distributed filesystem.☆214Updated 8 years ago
- ☆26Updated 5 years ago
- An Apache Storm IMetricsConsumer that forwards Storm's built-in metrics to a Graphite server for real-time graphing, visualization, and o…☆75Updated last year
- Collection of generic Apache Flink operators☆17Updated 7 years ago
- An extensions incubator for Reactor☆13Updated 8 years ago
- Use Avro to store all your values in HBase instead of regular columns☆75Updated 7 years ago
- A simple storm performance/stress test☆74Updated last year
- Mirror of Apache DirectMemory☆53Updated last year
- Winder is a simple state machine based on Quartz Scheduler. It helps to write multiple steps tasks on Quartz Scheduler. Winder derived fr…☆45Updated 2 years ago