Kafka consumer emitting messages as storm tuples
☆105Jan 8, 2021Updated 5 years ago
Alternatives and similar repositories for kafka-spout
Users that are interested in kafka-spout are comparing it to the libraries listed below
Sorting:
- Library to use Kafka as a spout within Storm☆43Sep 26, 2011Updated 14 years ago
- A collection of spouts, bolts, serializers, DSLs, and other goodies to use with Storm☆579Aug 23, 2022Updated 3 years ago
- storm kafka hdfs examples☆21Nov 28, 2016Updated 9 years ago
- Storm Elastic Search Bolt☆63Dec 17, 2023Updated 2 years ago
- Gevent Crawling in Python, with Utilities☆22Mar 12, 2015Updated 10 years ago
- Example of running the flume log4j appender using CDH4 Flume☆15Jan 17, 2013Updated 13 years ago
- Dropwizard Metrics Cassandra reporter☆17Apr 18, 2020Updated 5 years ago
- This demo shows how to collect customized events (such as app,web logs) via play! into flume.☆10Jan 27, 2015Updated 11 years ago
- [PROJECT IS NO LONGER MAINTAINED] Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streamin…☆724Mar 22, 2022Updated 3 years ago
- Storm components for interacting with HDFS file systems☆60Jul 21, 2017Updated 8 years ago
- An implementation and example of Partial Key Grouping for Apache Storm. Partial Key Grouping is a load balancing strategy for distributed…☆15Sep 14, 2015Updated 10 years ago
- A kafka source & sink for flume☆72Dec 10, 2013Updated 12 years ago
- NuCypher for Kafka. Start building from this module (it fetches the appropriate branch from Kafka repository)☆17Oct 13, 2017Updated 8 years ago
- Storm Cassandra Integration☆182Dec 17, 2023Updated 2 years ago
- Github commit count topology☆15Jan 31, 2015Updated 11 years ago
- Real-time analysis and visualization with Storm-AMQ-Camel-Websockets-Highcharts integration.☆26Jan 4, 2015Updated 11 years ago
- Mesos containerizer hooks for Docker☆251Mar 6, 2019Updated 7 years ago
- The first Open Source document analysis platform☆65Aug 2, 2021Updated 4 years ago
- ☆29Dec 22, 2015Updated 10 years ago
- Java library providing primitive collections.☆29Sep 29, 2018Updated 7 years ago
- RTSP Server and Client.☆22May 6, 2013Updated 12 years ago
- ☆24Mar 9, 2016Updated 10 years ago
- Apache Kafka HTTP Endpoint for producing and consuming messages from topics☆154Feb 12, 2015Updated 11 years ago
- Apache Storm☆6,668Updated this week
- ☆22Jul 6, 2017Updated 8 years ago
- A Storm metrics reporter module.☆24Oct 28, 2016Updated 9 years ago
- An import river similar to the elasticsearch mysql river☆38Mar 12, 2014Updated 11 years ago
- LCN dubbo demo☆23Nov 6, 2017Updated 8 years ago
- 一个基于Spring Boot的Storm开发手脚架，开箱即用！集成读写Kafka、写Redis、写MySQL示例。☆58Dec 6, 2018Updated 7 years ago
- Flink performance tests☆28Nov 13, 2019Updated 6 years ago
- flumeng-kafka-plugin☆77Aug 31, 2015Updated 10 years ago
- Example of how to create your own custom serializers for Kafka queues including JSON, Smile and Kryo☆25Mar 10, 2016Updated 9 years ago
- Streaming using Flink to connect Kafka and Elasticsearch☆30May 11, 2016Updated 9 years ago
- 采用Reactor模式，注册readycreate, readyfinish事件到更新服务UpdateService，通过处理后进行模型缓存，然后将消息转化为 dispatchThread消息分配模型需要的create, update, finish的事件进行单线程循环调度…☆31Jun 1, 2017Updated 8 years ago
- A HBase schema manager using XML based table definition files.☆67Jun 29, 2022Updated 3 years ago
- Mirror of Apache Chukwa☆85Mar 31, 2019Updated 6 years ago
- This repository contains the support materials for my Doing More with Java book.☆11Nov 3, 2016Updated 9 years ago
- A smart rebalancer written in bash☆18Feb 12, 2024Updated 2 years ago
- A SCADA system that uses prime for intrusion tolerance. Using PVBrowser as an HMI☆10May 27, 2015Updated 10 years ago