This repository was archived by the owner on Jan 22, 2026. It is now read-only.
Add functionality for cluster unavailability #8
Description
Description
The NApp requires a Kafka cluster that is accepting connections during start up, operations, and shut down. However, this application does not take these circumstances into account, and has lackluster retry implementations
Requirements
1: Implement retry functionality using the @Retry decorator provided by tenacity
2: Implement retry functionality for start up, operations, and shut down.