Skip to content

Conversation

@Nikita-Shupletsov
Copy link
Contributor

  • Introduced a new class - PartitionLeaderCache
  • Changed the usage of the cache to make calls atomic(e.g. getting cached and non-cached values as one call instead of two, deleting cached values as one call, not one by one)
  • Added an integration test that tests the concurrent access of the cache

Reviewers: Andrew Schofield [email protected]

* Introduced a new class - PartitionLeaderCache
* Changed the usage of the cache to make calls atomic(e.g. getting
cached and non-cached values as one call instead of two, deleting cached
values as one call, not one by one)
* Added an integration test that tests the concurrent access of the
cache

Reviewers: Andrew Schofield <[email protected]>
@Nikita-Shupletsov
Copy link
Contributor Author

the original PR: #21335

@viktorsomogyi
Copy link
Contributor

viktorsomogyi commented Jan 30, 2026

Approved the CI flow. Once it's green, I think it's good to be merged as it has been reviewed already.

@chia7712
Copy link
Member

> Task :core:checkstyleTest FAILED
[ant:checkstyle] [ERROR] /home/chia7712/project/kafka/core/src/test/java/kafka/admin/ConcurrentListOffsetsRequestTest.java:17:1: Import control file does not handle this package. [ImportControl]

@Nikita-Shupletsov could you please fix the error?

@chia7712
Copy link
Member

@Nikita-Shupletsov Maybe we could use dynamic call to overcome the access scope limit.

@Nikita-Shupletsov
Copy link
Contributor Author

@chia7712 taking a look

@Nikita-Shupletsov
Copy link
Contributor Author

Nikita-Shupletsov commented Jan 31, 2026

4.0 branch doesn't have clients/clients-integration-tests module, so I removed the test.
please let me know if it makes sense

cherry pick automatically moved the class to core, which is not correct, imo, as it is for scala

@chia7712
Copy link
Member

please let me know if it makes sense

Please check previous comment (#21374 (comment))

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants