kafka

kafka copied to clipboard

KAFKA-17306; Soften the validation when replaying tombstones

4

This patch fixes a few buts in the replay logic of the consumer group records: * The first issue is that the logic assumed that the group or the member...

dajac

KAFKA-16813: Add global timeout for "@Test" and "@TestTemplate" (For Github Action)

6

Jira: https://issues.apache.org/jira/browse/KAFKA-16813 add ClusterTest and ClusterTests timout for 30 seconds. This is testing for GitHub Action CI. ### Committer Checklist (excluded from commit message) - [ ] Verify design and...

m1a2st

KAFKA-16564: Apply `Xlint` to java code in core module

4

Jira: https://issues.apache.org/jira/browse/KAFKA-16564 We should apply the same `xlint` to java code in core module before we complete the code migration. ### Committer Checklist (excluded from commit message) - [ ]...

m1a2st

Jira: https://issues.apache.org/jira/browse/KAFKA-17407 In my opinion, the old test run twice in https://github.com/apache/kafka/blob/4a485ddb71c844acc8bf241feda1fcbffc5ce9be/core/src/test/scala/unit/kafka/server/ShareGroupHeartbeatRequestTest.scala#L460 and make the epoch plus twice is wired. I find the reponse like, it means the hearbeat doen't...

m1a2st

Clean-up sticky partitioner code a little bit

2

1. Using primitive data type 2. Using isEmpty() instead of checking size() for empty list

myasinkaji

KAFKA-14563: RemoveClient-Side AddPartitionsToTxn Requests

1

https://issues.apache.org/jira/browse/KAFKA-14563

CalvinConfluent

*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...

snehashisp

KAFKA-15309: part 1-Add custom error handler for RecordTooLargeException to Producer

1

Implementation of [KIP-1038](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1038%3A+Add+Custom+Error+Handler+to+Producer)

aliehsaeedii

KAFKA-15309: part 2-Add custom error handler for UnknownTopicOrPartitionException to Producer

1

aliehsaeedii

Ports several tools for topic configuration from the client side, to the broker-side. Several things are refactored: - Decoupling. On the client side, for example, RepartitionTopics was using the CopartitionedTopicEnforcer,...

lucasbru