kafka

kafka copied to clipboard

KAFKA-19168: MirrorMaker kafka_metrics_count metric is always incorrect

7

Provide tags (connector name and task index) so that we get a kafka.connect.mirror:type=kafka-metrics-count metric per task. - Set the connector name and task index in the metrics for MirrorSourceConnector and...

Yunyung

KAFKA-10357: Add explicit internal topic initialization for Kafka Streams

3

This PR implements the init() method described in KIP-698 to allow users to validate or prepare internal Kafka Streams topics before starting the application. The changes include: Introduced a public...

k-apol

This PR aims to reduce the size and scope of a [larger PR](https://github.com/apache/kafka/pull/19913) that contains changes related to [KIP 698](https://cwiki.apache.org/confluence/display/KAFKA/KIP-698%3A+Add+Explicit+User+Initialization+of+Broker-side+State+to+Kafka+Streams). Exceptions are added that will be thrown by a new...

k-apol

KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer

6

https://issues.apache.org/jira/browse/KAFKA-17853 - - There is an issue with the console share consumer where if the broker is unavailable, even after force terminating using ctrl-c, the consumer does not shut down...

ShivsundarR

KAFKA-18966: Change controller_num_nodes_override to override_num_isolated_controllers

4

Bounce the broker that hosting the controller can cause unnecessary downtime for the partition. Avoid creating only 1 controller node in the combined kraft mode. For more details please check...

CalvinConfluent

MINOR Capture heap dump after OOM on CI

9

We have seen a few OOM errors on trunk lately. This patch adds the ability to capture a heap dump when this happens so we can better determine if the...

mumrah

JIRA: KAFKA-17651 This patch aims to add controller support for `describeUserScramCredentials`. It's part of KIP-919.

frankvicky

KAFKA-18752: Fix the warning of no-operation caused by slf4j in building kafka

1

JIRA: KAFKA-18752 In KAFKA-18466, we remove the slf4j impl from runtime scope to fix the compatibility issue (see https://github.com/apache/kafka/pull/17373#issuecomment-2580893706). However, that also causes a side effect: when running some tasks,...

frankvicky

KAFKA-19306: Migrate LogCompactionTester to tools module

3

jira: [KAFKA-19306](https://issues.apache.org/jira/browse/KAFKA-19306)

yunchipang

Bump requests from 2.31.0 to 2.32.4 in /tests

1

Bumps [requests](https://github.com/psf/requests) from 2.31.0 to 2.32.4. Release notes Sourced from requests's releases. v2.32.4 2.32.4 (2025-06-10) Security CVE-2024-47081 Fixed an issue where a maliciously crafted URL and trusted environment will retrieve...

dependabot[bot]