kafka

kafka copied to clipboard

KAFKA-19026: AlterConfigPolicy incompatibility between ZK mode and KR…

13

…aft mode when using AlterConfigOp.OpType.SUBTRACT Modified ZkAdminManager.scala so that on OpType.SUBTRACT the policy receives the modified configs, as happens in KRaft mode. This similarly fixes the OpType.APPEND differences. Note that...

edoardocomar

KAFKA-15038: Replace topicIdByPartitionMap with MetadataCache instance in RemoteLogManager

13

Reopen https://github.com/apache/kafka/pull/14136 - Rebase with latest trunk and account for new changes - Replace `TopicPartition` with `TopicIdPartition` in `StopPartition` to handle a [case](https://github.com/apache/kafka/pull/20256#issuecomment-3205314494) where `MetadataCache` is updated first on removeTopic...

aheev

MINOR: Document kRaft voter auto join will add a removed voter immediately issue

8

Document auto join behaviour in upgrade.html

TaiJuWu

KAFKA-10721: Rewrite topology to allow for overlapping unequal topic subscriptions

1

### Background This PR addresses the limitation where `StreamsBuilder` throws a `TopologyException` when multiple source nodes subscribe to overlapping but not identical sets of topics. For example, the following code...

chickenchickenlove

KAFKA-18952: Fix flaky test in MonitorableSinkIntegrationTest

1

The test `testMonitorableSinkConnectorAndTask` is flaky due to a race condition between the task thread and the test thread. The `awaitRecords()` method uses a `CountDownLatch` that counts down in `TestableSinkTask.put()` for...

majialoong

KAFKA-19891: Suppress error-level heartbeat logs during consumer close

1

This PR improves the logging behavior in AbstractHeartbeatRequestManager when the heartbeat response is null due to an exception. Currently, TimeoutException / DisconnectException are logged at ERROR level with full stacktrace,...

AntonVasant