kafka

kafka copied to clipboard

Replace `singleton` with `Set.of` in the SubscriptionStateTest.

DL1231

Finalise the share group SimpleAssignor for homogeneous subscriptions. The assignor code is much more accurate about the number of partitions assigned to each member, and the number of members assigned...

AndrewJSchofield

KAFKA-19324: Make org.apache.kafka.common.test.TestUtils package-private to prevent cross-module access

3

Description * Replace `org.apache.kafka.common.test.TestUtils` with `org.apache.kafka.test.TestUtils` in outer package modules to standardize test utility usage * Move `waitUntilLeaderIsElectedOrChangedWithAdmin` method from `org.apache.kafka.test.TestUtils` to `ClusterInstance` and refactor for better code organization *...

YutaLin

KAFKA-19397: Not relaying on metadata to map between topic id and name.

3

- Metadata doesn't have the full view of topicNames to ids during rebootstrap of client or when topic has been deleted/recreated. The solution is to pass down topic id and...

OmniaGM

KAFKA-19070:: Adding task number to user provided client id to ensure each consumer has a unique client ID to avoid metric registration conflicts.

16

**What** This PR updates the behavior of client.id assignment when a user provides a custom value via override configs in Kafka Connect. **Why** Currently, if a user overrides the client.id,...

kumarpritam863

KAFKA-15599: Move KafkaMetadataLog to the raft module

12

- Rename `KafkaMetadataLog` to `KafkaRaftLog` - Make `raft` depend on `storage` - Remove `storage` dependency on `metadata` as this otherwise create a cyclic dependency

mimaison

KAFKA-18053 Clean up topology config

4

Pull request to implement KIP-1138, which aims to address several issues related to the configuration application process in Kafka Streams. This PR has multiple goals: - Deprecate `TopologyConfig` in favor...

sebastienviale

In KRaft, custom KafkaPrincipalBuilder instances must implement KafkaPrincipalSerde to support the forward mechanism. Currently, this requirement is not enforced and relies on the developer's attention. With this patch, we can...

johnny94

[https://github.com/apache/kafka/commit/ba7b5c9b327558ee0b0169cd6a22216eae7ee6cd](url)

rreddy-22

Fix IllegalStateException for Transaction Producer

2

Current Behavior: - When a batch fails with a fatal error (e.g., ProducerFencedException), the TM transitions to FATAL state - However, subsequent batches that fail can still trigger state transitions...

k-raina