storm-contrib
storm-contrib copied to clipboard
nathanmarz
A collection of spouts, bolts, serializers, DSLs, and other goodies to use with Storm
Satisfying #29, this commit introduced a .gitmodules.anon and symlinks .gitmodules to it, and a .gitmodules.ssh holding the privileged addresses for the various submodules. The result is that, by default, newcomers...
It's possible to get NoRouteToHostExceptions as well as ConnectExceptions when attempting to connect to the kafka broker. I don't think any others are possible, at least based on the docs...
Previously, when using a StringScheme, the Kafka spout would always output the Kafka messages in a field called "str"; in this pull request, the constructor to StringScheme takes a parameter...
Hi, Are there any plans or attemps at supporting Kafka 0.8? Thanks, Danijel
Hi, I have been trying to use kafka-spout with clojure but can not seem to get it to work - do you have an example for making a spout in...
PartitionManager resets to the offset of a failed message and upon nextTuple() starts re-transmitting all data from that offset forward. We modified this behavior to cache the data emitted and...
[At present](https://github.com/nathanmarz/storm-contrib/commit/77757923f6bc350d56858157025c8046faf7bd45#pom.xml) the pom.xml contains these entries: > > storm-contrib-core > storm-contrib-mongo > storm-contrib-sqs > Searching for a pom.xml, I get these contenders for actual modules: > storm-contrib/pom.xml > storm-contrib/storm-cassandra/examples/pom.xml...
Most users will checking this project out and following the wiki will immediately encounter: > storm-contrib$ git submodule update > Permission denied (publickey). > fatal: The remote end hung up...
Looks like twitter removed kafka client from their repo. Getting "com.twitter#kafka_2.9.2;0.7.0: not found"
RDBMSDumperBolt doesnt works in cluster mode. The constructor code must be moved to the prepare method, leaving only the initialization of variables in the constructor. It worked for me this...
Metadata
Owner
Metadata
A collection of spouts, bolts, serializers, DSLs, and other goodies to use with Storm