Added a connection timeout to Firehose::Producer so that we'd just throw an exception instead of hang our app
Added a connection timeout to Firehose::Producer so that we'd just throw an exception instead of hang our app

firehoseio/firehose,ramontayag/firehose,ramontayag/firehose