kafka

kafka copied to clipboard

Current comment on that class: A concurrent event accumulator which group events per key and ensure that only one event with a given key **can't** be processed concurrently. To my...

masonyc

(wip )KAFKA-19042 consumer bounce test

2

This PR do following: 1. rewrite `consumerBounceTest` to java 2. Move test to clients-intergration-test

TaiJuWu

KAFKA-19279: Make DefaultMessageFormatter public

3

Fixes https://issues.apache.org/jira/browse/KAFKA-19279

kumarlokesh

KAFKA-18149: Docs improvement for dynamic kraft quorum

1

* be specific that --command-config for add-controller needs to point to the to-be-added controller's config * be specific that `controller.quorum.bootstrap.servers` in the to-be-added controllers config needs to contain a controller...

FrankYang0529

KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol

2

We introduced new coordinator record for async kafka consumer like ConsumerGroupMetadataKey, ConsumerGroupPartitionMetadataKey, etc. The GroupMetadataMessageFormatter didn't support these message type. We should add another test case for consumer group protocol....

FrankYang0529

KAFKA-19381: add ConfigDef.ConfigKey.Builder

7

Added and extensible ConfigKey Builder class.

Claudenw

KAFKA-18193 Refactor Kafka Streams CloseOptions to Fluent API Style

2

In Kafka Streams, configuration classes typically follow a fluent API pattern to ensure a consistent and intuitive developer experience. However, the current implementation of `org.apache.kafka.streams.KafkaStreams$CloseOptions` deviates from this convention by...

m1a2st

This patch resolves the following issues in MetadataCache#toCluster: - Avoids duplicate Node entries when a broker has multiple endpoints. - Fixes a bug where fenced brokers result in NPE. -...

brandboat

Kafka-16355: Fix ConcurrentModificationException in evictWhile Method

5

This PR addresses an issue with the evictWhile method where a ConcurrentModificationException was being thrown due to modifications made to sortedMap during iteration. The following changes have been made: -...

abhi-ksolves

KAFKA-18061 AddRaftVoter responds with error message "NONE" instead of null

7

*Fix building 'Response.errorMessage' with 'RaftUtil #addVoterResponse' and' RaftUtil#removeVoterResponse' for 'Errors.NONE' is not 'null' but 'NONE' because When 'errorMessage' is passed in as 'null', 'Errors#message' is used to generate a default...

Linsiyuan9