kafka

kafka copied to clipboard

KAFKA-19897: Document support for testing with java 25 (3.9)

1

With #21026 completed, we can update the documentation to indicate support for testing with Java 25 in AK 3.9.

mingyen066

KAFKA-19086: Add support for microsecond precision for Connect

7

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

kumarlokesh

KAFKA-19884: Add tests to ensure Consumer.close() timeouts work as documented

2

Ensure that `close()` takes at least `DEFAULT_FETCH_MAX_WAIT_MS` milliseconds to close, and ensure that `close(CloseOptions)` with a short timeout closes before `DEFAULT_FETCH_MAX_WAIT_MS`.

kirktrue

KAFKA-10549: Add topic ID support to ListOffsets - client (2/N)

2

Base on https://github.com/apache/kafka/pull/21039, Implement list offset RPC support topicId for consumer part.

TaiJuWu

MINOR Clarified maximum length of COMPACT_STRING

1

This is a minor documentation change. Related to mailing list discussion [here](https://lists.apache.org/thread/d6lpwtqqzok69twndwzxx2zp09dmvjq8)

josefk31

(WIP) KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable

1

This PR aims to deliver [KIP-909](https://cwiki.apache.org/confluence/display/KAFKA/KIP-909%3A+DNS+Resolution+Failure+Should+Not+Fail+the+Clients).

frankvicky

## Summary - Remove `unstable.api.version.enable` config since it's not required. - Remove `testStreamsGroupHeartbeatIsInaccessibleWhenUnstableLatestVersionNotEnabled` test Reviewers: @lucasbru

lucliu1108

KAFKA-19980: ConfigCommand#validatePropsKey should accept `$` symbol

1

1. Enabled ConfigCommand#validatePropsKey to support the `$` symbol. 2. Added UT and IT for the change. Reviewers: Chia-Ping Tsai

DL1231

MINOR: Bytes lexicographic comparator could use compiler builtin

8

The `Arrays.compare` method has a vectorized compiler intrinsic available and should offer better performance than a hand-rolled loop. The JDK implementation is at least able to compare 8 bytes at...

stevenschlansker

KAFKA-13152: Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes"

7

This PR continues the work that was mostly completed but was unreviewed in #13283. This is part of [KIP-770](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=186878390) which is partially completed. I copied and pasted most of the...

shashankhs11