search

rakutentech / kafka-firehose-nozzle

Forward logs from the Cloud Foundry Firehose to Apache Kafka
MIT License
13 stars 8 forks source link

Handle upstream channel close #2

Closed tcnksm closed 8 years ago

tcnksm commented 8 years ago

We use noaa for consuming firehose logs. It closes event/error channels after five reconnection attempts (when something wrong on connection between nozzle and firehose).

Now this nozzle doesn't handle that situation (It continues loop...). This PR stops nozzle when noaa client closes channel.

tcnksm commented 8 years ago

@CAFxX Please have a look of this PR

tcnksm commented 8 years ago

Change PR target from master to develop

https://github.com/rakutentech/kafka-firehose-nozzle/pull/3