kaffe icon indicating copy to clipboard operation
kaffe copied to clipboard

Bugfix: Match on subscribe_to_topics success to avoid getting stuck

Open rodrigues opened this issue 4 years ago • 0 comments

In case the kafka cluster is temporarily unavailable, when subscribe_to_topics retries are exhausted, it simply exits the function without crashing.

When kafka cluster is back, if that happened after client_down_retry_expire, it won't subscribe to topics, and the consumer gets stuck.

With this change, it will crash after retries are exhausted and topic subscription didn't complete successfully, restarting properly as expected.

rodrigues avatar Dec 15 '21 11:12 rodrigues