test passing
Merge pull request #1 from omalab/master

Make broker connection robust to connection resets from kafka