Skip to content

KAFKA-13917: Avoid calling lookupCoordinator() in tight loop#12180

Merged
showuon merged 1 commit into
apache:trunkfrom
viktorsomogyi:KAFKA-13917-tight-loop
Jun 10, 2022
Merged

KAFKA-13917: Avoid calling lookupCoordinator() in tight loop#12180
showuon merged 1 commit into
apache:trunkfrom
viktorsomogyi:KAFKA-13917-tight-loop

Conversation

@viktorsomogyi

Copy link
Copy Markdown
Contributor

Committer Checklist (excluded from commit message)

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

@viktorsomogyi

viktorsomogyi commented May 20, 2022

Copy link
Copy Markdown
Contributor Author

@mimaison would you please review this short change if you get some time? (the tests seem to be flaky)

@divijvaidya divijvaidya left a comment

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM!

@viktorsomogyi

Copy link
Copy Markdown
Contributor Author

@hachikuji would you please review this small PR?

@showuon showuon left a comment

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM! Thanks.

@showuon

showuon commented Jun 10, 2022

Copy link
Copy Markdown
Member

Failed tests are unrelated:

    Build / JDK 11 and Scala 2.13 / org.apache.kafka.controller.QuorumControllerTest.testConfigurationOperations()
    Build / JDK 17 and Scala 2.13 / kafka.admin.TopicCommandIntegrationTest.testDescribeAtMinIsrPartitions(String).quorum=kraft
    Build / JDK 17 and Scala 2.13 / kafka.controller.ControllerIntegrationTest.testPartitionReassignmentToBrokerWithOfflineLogDir()

@showuon showuon merged commit f8f5796 into apache:trunk Jun 10, 2022
@ijuma

ijuma commented Jun 10, 2022

Copy link
Copy Markdown
Member

Do we need to backport this? Also cc @guozhangwang @dajac since this code has gone through a few iterations.

@showuon

showuon commented Jun 11, 2022

Copy link
Copy Markdown
Member

+1 to backport this change to 3.2. Let me know if necessary. Thanks.

rajinisivaram added a commit to confluentinc/kafka that referenced this pull request Jun 12, 2022
…-2022

* apache/trunk: (52 commits)
  KAFKA-13967: Document guarantees for producer callbacks on transaction commit (apache#12264)
  [KAFKA-13848] Clients remain connected after SASL re-authentication f… (apache#12179)
  KAFKA-10000: Zombie fencing logic (apache#11779)
  KAFKA-13947: Use %d formatting for integers rather than %s (apache#12267)
  KAFKA-13929: Replace legacy File.createNewFile() with NIO.2 Files.createFile() (apache#12197)
  KAFKA-13780: Generate OpenAPI file for Connect REST API (apache#12067)
  KAFKA-13917: Avoid calling lookupCoordinator() in tight loop (apache#12180)
  KAFKA-10199: Implement removing active and standby tasks from the state updater (apache#12270)
  MINOR: Update Scala to 2.13.8 in gradle.properties (apache#12273)
  MINOR: add java 8/scala 2.12 deprecation info in doc (apache#12261)
  ...

 Conflicts:
	gradle.properties
viktorsomogyi added a commit to viktorsomogyi/kafka that referenced this pull request Jul 18, 2022
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.

5 participants