Task #28318
Fix consumer hanging when Kafka becomes unreachable
Start date:
02/07/2025
Due date:
% Done:
100%
Estimated time:
Description
When Kafka connection was lost, the consumer goroutine exits but the main process continues running indefinitely. As a quick fix exit the process in such case so that k8s/systemd would restart it automatically.
In the future implement a proper circuit breaker.