rameeshm opened a new pull request, #1231: URL: https://github.com/apache/ranger/pull/1231
## What changes were proposed in this pull request? The patch addresses the issue where the AuditDispatcherBase.DispatcherWorker dies when Kafka is not ready yet. Retry Logic: It wraps the poll() and processing logic in a try-catch block. When an AuthorizationException or AuthenticationException is thrown, the worker now sleeps for a configurable delay (auth.retry.delay.ms) and continues the loop instead of exiting. Worker Health Monitoring: It adds monitorAndRestartWorkers() to the main thread's loop. If a worker thread terminates unexpectedly (e.g., due to an unhandled Error), the main thread will detect that its Future is done and restart the worker. ## How was this patch tested? Patch tested in docker with scenarios to repro the situation and see how resilient is AuditDispatcher is. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
