search

nathanmarz / storm-contrib

A collection of spouts, bolts, serializers, DSLs, and other goodies to use with Storm
Eclipse Public License 1.0
580 stars 340 forks source link

KafkaSpout should timeout all connection issues #24

Open nathanmarz opened 11 years ago

nathanmarz commented 11 years ago

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 future and give up after a timeout.