mailgun / kafka-pixy

gRPC/REST proxy for Kafka
Apache License 2.0
768 stars 119 forks source link

Initiate offset manager coordinator resolution on connection error #141

Closed horkhe closed 6 years ago

horkhe commented 6 years ago

When an OffsetMgr broker actor (the one responsible for sending OffsetCommitRequsets to a particular kafka broker) loses connection with the broker, that did not trigger Coordinator resolution for partition offset managers assigned to it. As a result their offsets never got commited. Note that it is not enough to just try reconnecting, because the broker could be down for an extended period of time and coordinator would have moved to another broker.

Fixes #140