Search results

MINOR: refactor warning message

coreKafka BrokerKafka Broker

smallSmall PRsSmall PRs

Status: Open (in progress).

apache/kafkanumber 21661

#21661 In apache/kafka;

· brandboat opened on Mar 6, 2026

KAFKA-20267 Move LogCleanerParameterizedIntegrationTest to storage module

coreKafka BrokerKafka Broker

storagePull requests that target the storage modulePull requests that target the storage module

testsTest fixes (including flaky tests)Test fixes (including flaky tests)

Status: Open (in progress).

apache/kafkanumber 21657

#21657 In apache/kafka;

· see-quick opened on Mar 6, 2026

KAFKA-19752: Move parts of UnifiedLogTest to storage module

coreKafka BrokerKafka Broker

storagePull requests that target the storage modulePull requests that target the storage module

testsTest fixes (including flaky tests)Test fixes (including flaky tests)

Status: Open (in progress).

apache/kafkanumber 21644

#21644 In apache/kafka;

· mimaison opened on Mar 5, 2026

KAFKA-20254: Add integration test for streams group migration with broker restart

buildGradle build or GitHub ActionsGradle build or GitHub Actions

coreKafka BrokerKafka Broker

group-coordinator

streams

Status: Open (in progress).

apache/kafkanumber 21642

#21642 In apache/kafka;

· lucasbru opened on Mar 5, 2026

KAFKA-20256: Add ShareGroupDLQ interface and some infra classes.

ci-approved

coreKafka BrokerKafka Broker

KIP-932Queues for KafkaQueues for Kafka

Status: Open (in progress).

apache/kafkanumber 21640

#21640 In apache/kafka;

· smjn opened on Mar 5, 2026

MINOR: Add test to enforce LATEST_STABLE_METADATA_VERSION sync with LATEST_PRODUCTION

buildGradle build or GitHub ActionsGradle build or GitHub Actions

coreKafka BrokerKafka Broker

smallSmall PRsSmall PRs

testsTest fixes (including flaky tests)Test fixes (including flaky tests)

Status: Open (in progress).

apache/kafkanumber 21637

#21637 In apache/kafka;

· unknowntpo opened on Mar 5, 2026

KAFKA-20162: Validation and enforcement of group configurations

ci-approved

coreKafka BrokerKafka Broker

group-coordinator

performance

Status: Open (in progress).

apache/kafkanumber 21633

#21633 In apache/kafka;

· majialoong opened on Mar 4, 2026

KAFKA-20207: handle the ClusterIdRecord as part of the metadata image

coreKafka BrokerKafka Broker

kraft

triagePRs from the communityPRs from the community

Status: Draft (not ready).

apache/kafkanumber 21632

#21632 In apache/kafka;

· kevin-wu24 opened on Mar 4, 2026

KAFKA-20251: Add configs for assignment batching and offload

coreKafka BrokerKafka Broker

group-coordinator

Status: Open (in progress).

apache/kafkanumber 21627

#21627 In apache/kafka;

· squah-confluent opened on Mar 4, 2026

KAFKA-20247: Controller registration needs to retry after request timeout

ci-approved

coreKafka BrokerKafka Broker

smallSmall PRsSmall PRs

Status: Open (in progress).

apache/kafkanumber 21619

#21619 In apache/kafka;

· kevin-wu24 opened on Mar 3, 2026

refactor: simplify code

coreKafka BrokerKafka Broker

kraft

smallSmall PRsSmall PRs

triagePRs from the communityPRs from the community

Status: Open (in progress).

apache/kafkanumber 21608

#21608 In apache/kafka;

· spotlesscoder opened on Mar 1, 2026

KAFKA-19562: Replace hand-written AbortedTxn with generated protocol

clients

coreKafka BrokerKafka Broker

storagePull requests that target the storage modulePull requests that target the storage module

tiered-storageRelated to the Tiered Storage featureRelated to the Tiered Storage feature

tools

Status: Open (in progress).

apache/kafkanumber 21577

#21577 In apache/kafka;

· mingyen066 opened on Feb 25, 2026