vamossagar12 commented on PR #14372: URL: https://github.com/apache/kafka/pull/14372#issuecomment-2149594178
Thanks @C0urante . hmm yeah you have a point, with the proposed approach in this PR, I end up failing the entire KafkaBasedLog machinery which is bad because it would need restarting the entire cluster even though the issue is fixable(like expiring certs etc) and a connector restart should fix it ideally. To summarise, I will make some changes which will => 1) Not let the WorkThread die permanently so that future read requests can be handled. 2) Propagate any such fatal errors to the connector/task status and fail them so that they become actionable. This way we can keep handling future read requests and also fail these connectors there by not amassing requests which can never be handled. Let me get back to you when I have the changes handy. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org