kafka

kafka copied to clipboard

KAFKA-19395 - Updated Junit and mockito version and license information in NOTICE-binary for Jakarta RESTful Web Services Project

4

Jira - https://issues.apache.org/jira/browse/KAFKA-19395 Updated Junit version and license information in NOTICE-binary for Jakarta RESTful Web Services Project Github pom.xml for Jakarta rest project - https://github.com/jakartaee/rest/blob/36de36005d52fc06fc050aa6def415abb255a539/pom.xml#L114 Maven for Junit 5.10.2 version...

kapoorpalak21999

Add the `ackWhenCommitted` boolean field to the `AddRaftVoterRequest` RPC, and bump the RPC's version to 1. - The default value of `ackWhenCommitted` is `true`, and in this case the leader...

kevin-wu24

KAFKA-19411: Fix deleteAcls bug which allows more deletions than max records per user op

1

If there are more deletion filters after we initially hit the `MAX_RECORDS_PER_USER_OP` bound, we will add an additional deletion record ontop of that for each additional filter. The current error...

ahuang98

KAFKA-19407 Fix potential IllegalStateException when appending to timeIndex

1

## Summary - Fix potential race condition in LogSegment#readMaxTimestampAndOffsetSoFar(), which may result in non-monotonic offsets and causes replication to stop. - See https://issues.apache.org/jira/browse/KAFKA-19407 for the details how it happen.

ocadaruma

KAFKA-18884: Move TransactionMetadata to transaction-coordinator module

6

1. Move TransactionMetadata to transaction-coordinator module. 2. Rewrite TransactionMetadata in Java.

FrankYang0529

parent: https://github.com/apache/kafka/pull/19687/files#r2094574178

yunchipang

KAFKA-19078: Implement automatic controller addition to cluster metadata partition

1

Add the `controller.quorum.auto.join.enable` configuration. When enabled with KIP-853 supported, follower controllers who are observers (their replica id + directory id are not in the voter set) will: - Automatically remove...

kevin-wu24

https://issues.apache.org/jira/browse/KAFKA-19383 When applying the ClearElrRecord, it may pick up the topicId in the image without checking if the topic has been deleted. This can cause the creation of a new...

CalvinConfluent

KAFKA-17573: Move KRaftMetadataCache to metadata module

5

## Changes * Move KRaftMetadataCache from core to metadata module * Change KRaftMetadataCache from Scala to Java ## Performance * ReplicaFetcherThreadBenchmark ``` ./jmh-benchmarks/jmh.sh -f 1 -i 2 -wi 2 org.apache.kafka.jmh.fetcher.ReplicaFetcherThreadBenchmark...

FrankYang0529

KAFKA-17259: Support to override serverProperties and restart cluster in ClusterTestExtensions

4

Add `restart` function to `ClusterInstance` and `KafkaClusterTestKit`.

FrankYang0529