Skip to content

HOTFIX: Enforce a rebalance upon task migration#4802

Merged
guozhangwang merged 2 commits intoapache:1.1from
guozhangwang:KHotfix-enforce-rebalance-1.1
Mar 31, 2018
Merged

HOTFIX: Enforce a rebalance upon task migration#4802
guozhangwang merged 2 commits intoapache:1.1from
guozhangwang:KHotfix-enforce-rebalance-1.1

Conversation

@guozhangwang
Copy link
Copy Markdown
Contributor

Unsubscribe / resubscribe a rebalance upon task migration (either false positive or not) to enforce a rebalance, also to refresh on log end offset

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

@guozhangwang
Copy link
Copy Markdown
Contributor Author

@mjsax @xvrl

@guozhangwang guozhangwang merged commit ca383b2 into apache:1.1 Mar 31, 2018
guozhangwang added a commit to confluentinc/kafka that referenced this pull request Apr 2, 2018
Unsubscribe / resubscribe a rebalance upon task migration (either false positive or not) to enforce a rebalance, also to refresh on log end offset

Reviewers: Guozhang Wang <wangguoz@gmail.com>
ijuma added a commit to confluentinc/kafka that referenced this pull request Apr 25, 2018
* confluent/1.1: (60 commits)
  MINOR: Fix kafka-run-class for Java 10 (apache#4895)
  KAFKA-6772: Load credentials from ZK before accepting connections (apache#4867)
  KAFKA-6742: TopologyTestDriver error when dealing with stores from GlobalKTable
  MINOR: Mention that -1 disables retention by time (apache#4881)
  KAFKA-6790: Fix Streams processor node broken link (apache#4874)
  MINOR: Java 10 fixes so that the build passes (apache#4839)
  MINOR: Update Jackson to 2.9.5 (apache#4776)
  MINOR: Downgrade to Gradle 4.5.1 (apache#4791)
  MINOR: Java 9/10 fixes, gradle and minor deps update (apache#4725)
  KAFKA-6752: Enable unclean leader election metric (apache#4838)
  KAFKA-6054: Fix upgrade path from Kafka Streams v0.10.0 (apache#4773)
  KAFKA-6747 Check whether there is in-flight transaction before aborting transaction (apache#4826)
  KAFKA-6748: double check before scheduling a new task after the punctuate call (apache#4827)
  KAFKA-6739; Ignore headers when down-converting from V2 to V0/V1 (apache#4813)
  KAFKA-6728: Corrected the worker’s instantiation of the HeaderConverter
  KAFKA-6731: waitOnState should check the state to be the target start. (apache#4808)
  HOTFIX: Enforce a rebalance upon task migration (apache#4802)
  MINOR: Remove 1.2.0 changes from streams doc (apache#4784)
  MINOR: Update version numbers to 1.1.1-SNAPSHOT
  MINOR: Fix ReassignPartitionsClusterTest.testHwAfterPartitionReassignment test (apache#4781)
  ...
@guozhangwang guozhangwang deleted the KHotfix-enforce-rebalance-1.1 branch April 24, 2020 23:48
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants