SOHU-Co / kafka-node / 1327 / 2

89%

master: 89%

cron

travis-ci

Improve consumer recovery (#1214)

* Fix issue where broker socket close did not schedule a refresh of internal metadata

* Add clientId to log messages to better distinguish clients

* Fix issue where reconnect and connect events were being emitted after failure to initialize broker

* Should refresh metadata when controller request fails

980 of 1479 branches covered (66.26%)

3072 of 3793 relevant lines covered (80.99%)

168.9 hits per line