KAFKA-17299: Fix Kafka streams consumer hang issue #17899
Merged
+1
−1
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
|
@mjsax : please review |
|
Thanks for the PR. Merged to I did play around with unit testing, and figured that it's more complex to write a proper unit test, and thus did a PR myself as follow up to this fix: #17919 Both, this fix and the unit test PR should be cherry-picked to older branches. Will do this, once the second PR was merged. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Kafka streams consumption completely stops and doesn't recover even after restart of the consumer instance/pod in some special cases where the deserialisation errors occurs for the first message in a batch.
This PR fixes the problem.