Apoorv Mittal

Incorrect publication file referenced with gradle signing and publication

1

### Shadow Version 'com.github.johnrengelman.shadow' version '8.1.1' ### Gradle Version 8.5 ### Expected Behavior The shadow jar artifact should be signed and published to repository. ### Actual Behavior The publication does...

KAFKA-17047: Refactored group coordinator classes to modern package (KIP-932)

1

Following the discussion and suggestion by @dajac, https://github.com/apache/kafka/pull/16054#discussion_r1613638293, the PR refactors the common classes to build TargetAssignment in `modern` package. `consumer` package has been moved inside `modern` package with classes...

KAFKA-17442: Handled persister errors with write async calls (KIP-932)

1

The PR makes the persister write RPC async. Also handles the errors from persister as per the review comment here: Addressing review comment for PR: https://github.com/apache/kafka/pull/16397#discussion_r1725454927 The read persister RPC...

KAFKA-17002: Integrated partition leader epoch for Persister APIs (KIP-932)

3

The PR integrates leader epoch for partition while invoking Persister APIs. The write RPC is retried once on leader epoch failure. ### Committer Checklist (excluded from commit message) - [...

KAFKA-17774: Adding capability to handle max fetch records in Share Fetch (KIP-932)

2

The PR adds capability to restrict the messages in Share Fetch. The max fetch records will be an additional way to limit the number of records sent from broker to...

KAFKA-17813: Moving broker endpoint class and common server connection id

7

### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including...

KAFKA-17545: Removing process fetch queue

1

The PR removed the process fetch queue as we have moved to share fetch purgatory. As the fetches are passed to purgatory hence close of SharePartitionManager can't validate if all...