search

wvanbergen / kafka

Load-balancing, resuming Kafka consumer for go, backed by Zookeeper.
MIT License
373 stars 141 forks source link

Handle reconnects [WIP] #98

Closed warebot closed 8 years ago

warebot commented 8 years ago

@wvanbergen

Re: issue #95 and #81

Clearly this a work in progress. I tested this approach locally and it seems to do the job. The idea is to "reconnect" the consumption for a topic+partition when encountering upstream failures e.g. sarama library closing channel.

Would like to get your initial thoughts. (clearly error handling would be added/implemented in the final commit)

warebot commented 8 years ago

Something went terribly wrong as there was a concurrent merge happening.. Closing and resubmitting.