kafka

kafka copied to clipboard

Removed the deprecated through method The method through in Java and Scala class KStream was deprecated in version 2.6: - org.apache.kafka.streams.scala.kstream.KStream#through - org.apache.kafka.streams.kstream.KStream#through(java.lang.String) - org.apache.kafka.streams.kstream.KStream#through(java.lang.String, org.apache.kafka.streams.kstream.Produced)

ardada2468

KAFKA-15615: Improve handling of fetching during metadata updates

8

# Problem As stated in the [KAFKA-15615](https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-15615) When a fetch response receives an error about partition leadership, fencing, etc. a metadata refresh is triggered. Until its metadata is updated, the...

appchemist

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

mimaison

Jira: https://issues.apache.org/jira/browse/KAFKA-17408 When I ran this test case in my local machine, I found the error is ``` org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 9384ms...

m1a2st

Jira: https://issues.apache.org/jira/browse/KAFKA-17390 *More detailed description of your change, Remove broker-list in GetOffsetShell *Summary of testing strategy (including rationale) for the feature or bug fix. Unit and/or integration tests are expected...

TaiJuWu

KAFKA-17414: Move RequestLocal to server-common module

1

Moved RequestLocal from core to server-common module. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build...

wernerdv

This is a shim to allow the use of both modern (JRE 18+) and legacy APIs (deprecated in 17, degraded in 23, removal unknown) related to [JEP 411: Deprecate the...

gharris1727

Initial support for OpenJDK CRaC snapshotting

11

This change intends to support an application using Vertx GRPC server to perform the Checkpoint and Restore on JVM implementing this, specifically using [OpenJDK CRaC](https://github.com/openjdk/crac/tree/crac) or future versions of OpenJDK....

rvansa

KAFKA-16617: Include kraft handler in advertised listener doc

1

As per [KAFKA-16617](https://issues.apache.org/jira/browse/KAFKA-16617), this PR revised the documentation for `advertised.listeners` to include kraft handler. ### Committer Checklist (excluded from commit message) - [x] Verify design and implementation - [x] Verify...

Owen-CH-Leung

KAFKA-16414: Inconsistent active segment expiration behavior between retention.ms and retention.bytes

1

Approach 1: make `retention.bytes` roll active segment when active segment size > `retention.bytes` Leave this draft and evaluate the scope of CI affected by this commit. ### Committer Checklist (excluded...

brandboat