kafka

kafka copied to clipboard

KAFKA-17686: AsyncKafkaConsumer.offsetsForTimes() fails with NullPointerException

4

The code to convert the `Map` was initially expressed using the Streams API with `collect(Collectors.toMap())`. Unfortunately, the implementation of `Collector` returned by `Collectors.toMap()` does not support `null` entries. The `KafkaConsumer.offsetsForTimes()`...

kirktrue

KAFKA-17645: KIP-1052: Enable warmup in producer performance test

2

In order to better analyze steady-state performance of Kafka, this PR enables a warmup in the Producer Performance test. The warmup duration is specified as a number of records that...

matt-welch

KAFKA-17600: Add nextOffsets to the ConsumerRecords

4

This PR implements KIP-1094.

aliehsaeedii

Upgrade protobuf-java library to version 4.28.2, that bring much enhancements and bug fixing comparing to the existing 3.X one the version 4.x is backward compatible with Protobuf 3.x at the...

bmscomp

Kafka 17792 header parsing times out processing and using large quantities of memory if the string looks like a number

5

Jira [KAFKA-17792](https://issues.apache.org/jira/browse/KAFKA-17792) We have trace headers such as: "X-B3-SpanId": "74320e6e26adc8f8" if however the value happens to be: "407127e212797209" This is then treated as a numeric value and it tries to...

msillence

The purpose of this pull request is to removed the duplicated code existing in the `ByteUtilsBenchmark.java` class and use the existing one on `ByteUtils.java ` no other changes was made...

bmscomp

With EOSv1 removed, we don't need to collect producer's clientInstanceIds per task any longer. While we never completed this feature, we can remove the corresponding scaffolding code.

mjsax

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

kirktrue

KAFKA-17337: ConsumerConfig should default to CONSUMER for group.protocol

1

Updated `DEFAULT_GROUP_PROTOCOL` to use `CONSUMER` instead of `CLASSIC`, updated `GROUP_PROTOCOL_DOC` to be a little more flexible going forward, and cleaned up unit tests that assumed `CLASSIC` as the default group...

kirktrue

KAFKA-17730: Fix ReplicaFetcherThreadBenchmark

2

NotLeaderOrFollowerException occurs here https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/RemoteLeaderEndPoint.scala#L188 The current fix is to catch and ignore NotLeaderOrFollowerException. Local benchmark result: ``` ./jmh-benchmarks/jmh.sh ReplicaFetcherThreadBenchmark running gradlew :jmh-benchmarks:clean :jmh-benchmarks:shadowJar > Configure project : Starting build with...

wernerdv