KAFKA-1414: Speedup broker shutdown and startup after hard reset#26
Closed
ataraxer wants to merge 1 commit intoapache:trunkfrom
ataraxer:kafka-1414
Closed
KAFKA-1414: Speedup broker shutdown and startup after hard reset#26ataraxer wants to merge 1 commit intoapache:trunkfrom ataraxer:kafka-1414
ataraxer wants to merge 1 commit intoapache:trunkfrom
ataraxer:kafka-1414
Conversation
ataraxer
changed the title
…hed by Alexey Ozeritskiy, Dmitry Bugaychenko and Anton Karamanov
Contributor
Author
|
Closed with f489493 |
ymatsuda
added a commit
to ymatsuda/kafka
that referenced
this pull request
Sep 1, 2015
get source topic names from builder and subscribe topics
resetius
added a commit
to resetius/kafka
that referenced
this pull request
Apr 22, 2016
remove snapshot
zzmao
pushed a commit
to zzmao/kafka
that referenced
this pull request
Jun 21, 2019
…e#26) Always set lastCommittedPartitionsAndOffsets in old ZookeeperConsumerConnector. Currently lastCommittedPartitionsAndOffsets is only set when offsetsToCommit is not empty and commit succeed, this causes problems during consumer migration when commit fails or have nothing to commit, since during migration, consumer will first try to get lastCommittedPartitionsAndOffsets from zk, then commit them to kafka. If lastCommittedPartitionsAndOffsets is not updated when commit fails or nothing to commit, it will keep getting the old committed offsets, thus can overwrite correct offsets.
xiowu0
pushed a commit
to xiowu0/kafka
that referenced
this pull request
Aug 23, 2019
…sumer (apache#26) TICKET = LI_DESCRIPTION = Always set lastCommittedPartitionsAndOffsets in old ZookeeperConsumerConnector. Currently lastCommittedPartitionsAndOffsets is only set when offsetsToCommit is not empty and commit succeed, this causes problems during consumer migration when commit fails or have nothing to commit, since during migration, consumer will first try to get lastCommittedPartitionsAndOffsets from zk, then commit them to kafka. If lastCommittedPartitionsAndOffsets is not updated when commit fails or nothing to commit, it will keep getting the old committed offsets, thus can overwrite correct offsets. EXIT_CRITERIA = MANUAL ["When old scala consumer is removed"]
ying-zheng
added a commit
to ying-zheng/kafka
that referenced
this pull request
Dec 24, 2019
offset and timestamp lookup for remote data
efeg
pushed a commit
to efeg/kafka
that referenced
this pull request
Jan 29, 2020
Change scala version to 2.11 Remove the commented out code in LeaderBytesInDistributionGoals Allow disabling parallel testing to make CircleCI happy Add gradle.properties to throttle memory utilization. Remove the stacktrace print in RandomSelfHealingTest.
divijvaidya
added a commit
to divijvaidya/kafka
that referenced
this pull request
May 12, 2022
…ighest tiered offset and the LEO of a partition (apache#26) * Add a TierLag metric to track the difference in offsets between the highest tiered offset and the LEO of a partition. Co-authored-by: Alexandre Dupriez <duprie@amazon.com>
jeqo
pushed a commit
to jeqo/kafka
that referenced
this pull request
Jun 14, 2023
…-docker Add Docker image building
lianetm
pushed a commit
to lianetm/kafka
that referenced
this pull request
Jul 19, 2023
…mer to Consumer (apache#26) Update the integration tests to swap the use of the concrete KafkaConsumer class to the generic Consumer interface. Swapped out KafkaConsumer for PrototypeAsyncConsumer.
patrik-marton
pushed a commit
to patrik-marton/kafka
that referenced
this pull request
Mar 11, 2025
CSMDS-219: Upgrade ZK (apache#26) becaue of CVE-2023-44981 Zk upgrade and version moved to properties for replacement (apache#32) CSMDS-483: Bump ZK version to 3.8.1.7.2.18.0-641 (apache#38) CSMDS-561: Update ZK to 3.8.1.7.2.18.200-37 (apache#77)
fvaleri
pushed a commit
to fvaleri/kafka
that referenced
this pull request
Sep 26, 2025
Fix stuck mirroring after source leader election
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
1 participant
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-1414