kafka
kafka copied to clipboard
MINOR: clear inFlightCorrelationId when ConnectionState is changed to READY
When a request is timed out, a old inFlightCorrelationId value is remaining
This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please ask a committer for review. If the PR has merge conflicts, please update it with the latest from trunk (or appropriate release branch)
If this PR is no longer valid or desired, please feel free to close it. If no activity occurs in the next 30 days, it will be automatically closed.