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 2 years ago
Related projects: ⓘ
- ☆24Updated this week
- Hadoop Data Integration with various databases, ftp servers, salesforce. Incremental update, dedup, append, merge your data on Hadoop.☆91Updated 11 years ago
- Lucene based indexing in Cassandra☆61Updated 8 years ago
- Metrics produced to Kafka and consumers for monitoring them☆101Updated 9 years ago
- A set of tools to ease working with Zookeeper and Kafka.☆23Updated 8 years ago
- Calliope is a library integrating Cassandra and Spark framework.☆28Updated 9 years ago
- A bunch of utility classes for Java, Hadoop, HBase, Pig, etc.☆76Updated 10 years ago
- Experiments in Streaming☆60Updated 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
- This project allows to run Samza jobs on Mesos cluster☆43Updated 3 years ago
- ☆26Updated 4 years ago
- Library to use Kafka as a spout within Storm☆43Updated 12 years ago
- Kafka Source and Sink Connectors☆19Updated 6 years ago
- Distributed Java Collections for ZooKeeper☆109Updated 8 years ago
- This project allows to run Samza jobs on Mesos cluster☆13Updated 7 years ago
- RxJava client for Apache Mesos HTTP APIs☆42Updated 5 years ago
- Basic tutorial for working with Apache Cassandra in Java via the Hector client☆129Updated 3 years ago
- An asynchronous graphite proxy☆34Updated last week
- Mirror of Apache DirectMemory☆53Updated 9 months ago
- Statsd reporter for codahale/metrics.☆93Updated 5 years ago
- ☆22Updated 7 years ago
- NIO implementation of a SMTP/LMTP Client☆64Updated 2 years ago
- This project provides utilities and wrappers around ZooKeeper☆64Updated 11 years ago
- ☆44Updated this week
- Java integration for collectd☆92Updated 13 years ago
- recordbus: mysql binlog to apache kafka☆80Updated 9 years ago
- Storm Cassandra Integration☆180Updated 9 months ago
- A lightweight platform monitoring tool for Java VMs☆155Updated 7 years ago
- A small project to report offset lag for Kafka Consumer Groups via Burrow.☆31Updated 4 years ago
- A keen Observer of changes that can also relay change events reliably to interested parties. Provides useful infrastructure for building …☆23Updated 9 months ago
- Allows a Storm topology to consume an AMQP exchange as an input source.☆54Updated 11 years ago