VinceMu opened a new pull request #8967: URL: https://github.com/apache/kafka/pull/8967
Work in progress, appreciate any feedback on my initial approach. Adding a disconnect status to Kafka streams. This is achieved by introducing by recording fetch disconnectedExceptions in Fetcher and then measuring them through 2 new metrics _fetchRequestSuccessPercent_ and _fetchRequestFailurePercent_. Currently when the percentage of failed fetches is above an arbitrary threshold we transition the streamThread to a disconnected state. Then when percentage of failed fetches dips below another arbitrary threshold we transition the streamThread to it's previous state. If my approach is satisfactory, I'll start writing tests. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
