Yelp / kafka-utils

Apache License 2.0
314 stars 128 forks source link

Make kafka_check/offline resilient to topic deletion #244

Closed flavray closed 4 years ago

flavray commented 4 years ago

In the case where topics are being deleted while the offline check is running, there can be a race condition making the topic_partitions dict inconsistent (slot not updated because some data in topic_partitions is not part of resp as a topic was deleted in between).