Closed
Conversation
This makes exporting jmx metrics via the deployed debian package much easier. See https://github.com/jmxtrans/jmxtrans-agent NOTE: the inclusion of the jmxtrans-agent jar is mostly for the migration tool as well as the mirror maker, which doesn't expose an easy way to export metrics to graphite
See {T63657}
This reverts commit 505e2d0.
Reviewers: grk Reviewed By: grk Differential Revision: https://code.uberinternal.com/D83314
Summary: * Add a new gradle project for the migrator tool * Update .gitignore * KafkaMigrationTool is just copy-pasted. Test Plan: ./gradlew test Reviewers: grk, praveen, vinoth, csoman, norbert Reviewed By: norbert Subscribers: bigpunk, nharkins Maniphest Tasks: T67641 Differential Revision: https://code.uberinternal.com/D83463
Summary: * check topic whiltelist/blacklist before running the migration tool * fix corrupted offsets upon detection * fail fast on erorrs and sigterm Test plan: * Added unit tests * Manually tested that corrupted offsets are fixed Reviewers: norbert, grk, praveen, csoman, vinoth Subscribers: nharkins, bigpunk Maniphest Tasks: T67641 Differential Revision: https://code.uberinternal.com/D84682
Summary: * check topic whiltelist/blacklist before running the migration tool * fix corrupted offsets upon detection * fail fast on erorrs and sigterm Test plan: * Added unit tests * Manually tested that corrupted offsets are fixed Reviewers: norbert, grk, praveen, csoman, vinoth Subscribers: nharkins, bigpunk Maniphest Tasks: T67641 Differential Revision: https://code.uberinternal.com/D84682
ymatsuda
added a commit
to ymatsuda/kafka
that referenced
this pull request
Sep 14, 2015
call statemgr.close()
resetius
added a commit
to resetius/kafka
that referenced
this pull request
Aug 14, 2016
[KAFKA-3038][LOGBROKER-1660] import Eno Thereska's patch
xiowu0
pushed a commit
to xiowu0/kafka
that referenced
this pull request
Oct 10, 2019
…r election. (apache#52) [LI-HOTFIX] Log the partition being made online due to unclean leader election. TICKET = KAFKA-8969 LI_DESCRIPTION = Log unclean leader election at the warn level. Add additional unit tests for unclean leader election. EXIT_CRITERIA = TICKET [KAFKA-8969]
efeg
pushed a commit
to efeg/kafka
that referenced
this pull request
Jan 29, 2020
…ke them consistent with /proposals (apache#52)
Hangleton
pushed a commit
to Hangleton/kafka
that referenced
this pull request
Apr 27, 2020
…age test utils. - Added consume records and other tests, and refactoring of tiered storage test utils. - Added broker id to the configuration properties of RSM. - Added test for disaster recovery with deletion of broker local storage on leader. (apache#52 ) Reviewed-by: satishd@apache.org
smccauliff
added a commit
to smccauliff/kafka
that referenced
this pull request
Oct 8, 2020
… election. (apache#52) [LI-HOTFIX] Log the partition being made online due to unclean leader election. TICKET = KAFKA-8969 LI_DESCRIPTION = Log unclean leader election at the warn level. Add additional unit tests for unclean leader election. EXIT_CRITERIA = TICKET [KAFKA-8969]
wyuka
pushed a commit
to wyuka/kafka
that referenced
this pull request
Jan 14, 2022
… election. (apache#52) TICKET = KAFKA-8969 LI_DESCRIPTION = Log unclean leader election at the warn level. Add additional unit tests for unclean leader election. EXIT_CRITERIA = TICKET [KAFKA-8969]
wyuka
pushed a commit
to wyuka/kafka
that referenced
this pull request
Jan 16, 2022
… election. (apache#52) TICKET = KAFKA-8969 LI_DESCRIPTION = Log unclean leader election at the warn level. Add additional unit tests for unclean leader election. EXIT_CRITERIA = TICKET [KAFKA-8969]
wyuka
pushed a commit
to wyuka/kafka
that referenced
this pull request
Mar 4, 2022
… election. (apache#52) TICKET = KAFKA-8969 LI_DESCRIPTION = Log unclean leader election at the warn level. Add additional unit tests for unclean leader election. EXIT_CRITERIA = TICKET [KAFKA-8969]
wyuka
pushed a commit
to wyuka/kafka
that referenced
this pull request
Mar 28, 2022
… election (apache#52) TICKET = KAFKA-8969 LI_DESCRIPTION = Log unclean leader election at the warn level. Add additional unit tests for unclean leader election. EXIT_CRITERIA = TICKET [KAFKA-8969]
wyuka
pushed a commit
to wyuka/kafka
that referenced
this pull request
Jun 16, 2022
… election (apache#52) TICKET = KAFKA-8969 LI_DESCRIPTION = Log unclean leader election at the warn level. Add additional unit tests for unclean leader election. EXIT_CRITERIA = TICKET [KAFKA-8969]
rustd
pushed a commit
to rustd/pranavfinaldemokafka
that referenced
this pull request
Feb 9, 2024
…pache#52) When using `kafka-features.sh` with the `--feature` parameter, we expect a numeric feature level (e.g. `metadata.version=5`). The help example suggests that we can also use a descriptive version string for `metadata.version` such as `3.3-IV3`, which doesn't work. Reviewers: David Jacot <djacot@confluent.io> Co-authored-by: Jason Gustafson <jason@confluent.io>
fvaleri
added a commit
to fvaleri/kafka
that referenced
this pull request
Dec 19, 2025
Add minor refactoring for javadoc
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.
No description provided.