storm-contrib

storm-contrib copied to clipboard

If trying to connect to a port that is running something other than kafka, the kafka client can hang indefinitely. Instead, KafkaSpout (both Storm and Trident) should connect in a...

nathanmarz

When I run given MapExample usign storm 0.8.1 and cloudera hadoop 0.20.2 there is serization issue. Exception in thread "main" java.lang.RuntimeException: java.io.NotSerializableException: org.apache.hadoop.hdfs.DistributedFileSystem at backtype.storm.utils.Utils.serialize(Utils.java:47) at backtype.storm.topology.TopologyBuilder.createTopology(TopologyBuilder.java:89) at storm.state.example.MapExample.main(MapExample.java:126)

saxenaamit

Update maven dependencies for storm-kafka

2

Hi, Is it possible to update storm-kafka in clojar ? Last release of storm-kafka is really interresting but not available from maven. It also "depend on 0.9.0-wip1" wich is also...

avianey