KAFKA-948 : Update ReplicaStateMachine.scala#5
Closed
dibbhatt wants to merge 1 commit intoapache:0.8.0-beta1-candidate1from
dibbhatt:patch-1
Closed
KAFKA-948 : Update ReplicaStateMachine.scala#5dibbhatt wants to merge 1 commit intoapache:0.8.0-beta1-candidate1from dibbhatt:patch-1
dibbhatt wants to merge 1 commit intoapache:0.8.0-beta1-candidate1from
dibbhatt:patch-1
Conversation
KAFKA-948 When the broker which is the leader for a partition is down, the ISR list in the LeaderAndISR path is updated. But if the broker , which is not a leader of the partition is down, the ISR list is not getting updated. This is an issue because ISR list contains the stale entry.
ymatsuda
pushed a commit
to ymatsuda/kafka
that referenced
this pull request
Aug 21, 2015
Alternative API with KStream on top of Processor
Parth-Brahmbhatt
added a commit
to Parth-Brahmbhatt/kafka
that referenced
this pull request
Oct 15, 2015
BUG-40757: Making Authorizer ACL check for list as one of the 3 requi…
benstopford
pushed a commit
to benstopford/kafka
that referenced
this pull request
Dec 18, 2015
KAFKA-2979: Added SSL support for security rolling upgrade. Refactor.
Contributor
Author
resetius
added a commit
to resetius/kafka
that referenced
this pull request
Jun 7, 2016
Fix logging, fix truncation
jamesrgrinter
pushed a commit
to jamesrgrinter/kafka
that referenced
this pull request
Feb 2, 2018
Add 0 -> 1 translation forMapR Streams offset position on empty topic…
kehuum
pushed a commit
to kehuum/kafka
that referenced
this pull request
Mar 27, 2019
abhishekmendhekar
pushed a commit
to abhishekmendhekar/kafka
that referenced
this pull request
Jun 12, 2019
…instead of in .travis.yml (apache#5) TICKET = LI_DESCRIPTION = EXIT_CRITERIA = MANUAL ["describe exit criteria"]
xiowu0
pushed a commit
to xiowu0/kafka
that referenced
this pull request
Jul 10, 2019
TICKET = LI_DESCRIPTION = [LI-HOTFIX] Add build changes to publish github LinkedIn Kafka artifacts to bintray (#1) TICKET = LI_DESCRIPTION = [NOTE] This is a temporary measure to publish artifacts until CI is properly set up to do the job automatically. Users are not expected to run this themselves. EXIT_CRITERIA = MANUAL ["describe exit criteria"] [LI-HOTFIX] Add changes for CI builds and publishing artifacts to bintray. (#2) TICKET = LI_DESCRIPTION = Travis will kick off a build and publish artifacts to bintray upon creating a tag in the "x.y.z.w" format. EXIT_CRITERIA = MANUAL ["describe exit criteria"] [LI-HOTFIX] Try different encrypted bintray-related env variables for Travis (apache#4) TICKET = LI_DESCRIPTION = Travis couldn't access one of the initially encrypted variables for some reason. EXIT_CRITERIA = MANUAL ["describe exit criteria"] [LI-HOTFIX] Set Bintray-related env variables via repository setting instead of in .travis.yml (apache#5) TICKET = LI_DESCRIPTION = EXIT_CRITERIA = MANUAL ["describe exit criteria"] [LI-HOTFIX] Use the maven repo under the LinkedIn Bintray account to publish artifacts (apache#25) TICKET = LI_DESCRIPTION = EXIT_CRITERIA = MANUAL ["describe exit criteria"] EXIT_CRITERIA = MANUAL ["describe exit criteria"] # EXIT_CRITERIA = <EXIT_CRITERIA> <PARAMETERS> # e.g., # when the specified hash(s) is presented in the history, this commit is no longer needed: # EXIT_CRITERIA = HASH [<hash1>, <hash2> ...] # When the specified tickets are closed and there are patches with these tickets in the title in the commit history, this commit is no longer needed: # EXIT_CRITERIA = TICKET [<ticket1>, <ticket2> ...] # The exit criteria for this commit requires manual investigation: # EXIT_CRITERIA = MANUAL [<description>]
lianetm
pushed a commit
to lianetm/kafka
that referenced
this pull request
Jun 12, 2023
NodeStatusDetector is a new interface that abstracts two the methods from ConsumerNetworkClient (isUnavailable and maybeThrowAuthFailure) for use in NetworkClientDelegate. This allows the shared code (e.g. AbstractFetch) to bridge between those two implementations.
apalan60
referenced
this pull request
in apalan60/kafka
Apr 21, 2025
apalan60
referenced
this pull request
in apalan60/kafka
Apr 28, 2025
FrankYang0529
pushed a commit
to FrankYang0529/kafka
that referenced
this pull request
Aug 28, 2025
feat: change readonly to false
This file contains hidden or 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
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
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-948
When the broker which is the leader for a partition is down, the ISR list in the LeaderAndISR path is updated. But if the broker , which is not a leader of the partition is down, the ISR list is not getting updated. This is an issue because ISR list contains the stale entry.