Skip to content

Pull requests: apache/kafka

New pull request New
288 Open 21,195 Closed
288 Open 21,195 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (5/N) streams triage PRs from the community
#21497 opened Feb 17, 2026 by frankvicky • Draft
MINOR: Move ProducerIntegrationTest to clients-integration-tests and rewrite in Java triage PRs from the community
#21496 opened Feb 17, 2026 by mingyen066 Loading…
KAFKA-20106: Ensure reconciled assignment updated within poll clients consumer
#21495 opened Feb 17, 2026 by lianetm Loading…
1
MINOR: Avoid repeated logger creation in InternalTopicManager group-coordinator performance
#21494 opened Feb 17, 2026 by lucasbru Loading…
1
KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (4/N) streams triage PRs from the community
#21493 opened Feb 17, 2026 by frankvicky • Draft
MINOR: Rename ConfiguredTopology to TopologyValidationResult group-coordinator performance streams
#21492 opened Feb 17, 2026 by lucasbru • Draft
2 tasks done
KAFKA-20159: Group configuration for share.delivery.count.limit clients core Kafka Broker group-coordinator KIP-932 Queues for Kafka triage PRs from the community
#21491 opened Feb 17, 2026 by TaiJuWu Loading…
3
KAFKA-20173: Propagate headers into serde 1/N ci-approved streams
#21490 opened Feb 16, 2026 by UladzislauBlok Loading…
9
KAFKA-10731: Add support for SSL hot reload clients triage PRs from the community
#21488 opened Feb 16, 2026 by RedN4ks • Draft
KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (3/N) streams triage PRs from the community
#21486 opened Feb 16, 2026 by frankvicky • Draft
4
MINOR: Add 4.2.0 to the CVE Scanner build Gradle build or GitHub Actions ci-approved small Small PRs
#21485 opened Feb 16, 2026 by clolov Loading…
KAFKA-200135 Add javadoc to org.apache.kafka.clients.admin module(1/N) clients triage PRs from the community
#21484 opened Feb 16, 2026 by m1a2st Loading…
KAFKA-18608 [WIP]: Add Support for OAuth Client Assertion to client_credentials Grant Type build Gradle build or GitHub Actions ci-approved clients triage PRs from the community
#21483 opened Feb 16, 2026 by prabhashkr Loading…
KAFKA-20189: Add character class support to GlobComponent tools triage PRs from the community
#21482 opened Feb 15, 2026 by akramdevstuffs Loading…
MINOR: Replace Properties with Map in ControllerConfigurationValidator validation path ci-approved core Kafka Broker group-coordinator small Small PRs storage Pull requests that target the storage module triage PRs from the community
#21481 opened Feb 15, 2026 by majialoong Loading…
KAFKA-19976: Deprecate streams-scala module ci-approved kip Requires or implements a KIP streams
#21480 opened Feb 15, 2026 by FrankYang0529 Loading…
9
MINOR: Add argument description for --override option core Kafka Broker small Small PRs
#21479 opened Feb 14, 2026 by devdriven05 Loading…
2
KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (2/N) small Small PRs streams
#21478 opened Feb 13, 2026 by frankvicky • Draft
1
KAFKA-19915: [3/3] Move LogDeleteRecordsResult to server module core Kafka Broker small Small PRs triage PRs from the community
#21477 opened Feb 13, 2026 by clolov Loading…
KAFKA-15529: Fix race condition between isConsumed and position updates in AsyncKafkaConsumer fetch path build Gradle build or GitHub Actions ci-approved clients consumer small Small PRs triage PRs from the community
#21476 opened Feb 13, 2026 by majialoong Loading…
1
KAFKA-19915: [2/3] Move HostedPartition to server module core Kafka Broker storage Pull requests that target the storage module
#21475 opened Feb 13, 2026 by clolov Loading…
8
KAFKA-20146: Add CI check to detect Python dependency conflicts build Gradle build or GitHub Actions small Small PRs triage PRs from the community
#21472 opened Feb 13, 2026 by mingyen066 Loading…
KAFKA-20118: Improve the error message caused by normally moving replica ci-approved core Kafka Broker small Small PRs triage PRs from the community
#21470 opened Feb 13, 2026 by Parkerhiphop Loading…
KAFKA-20090: Add recovery logic to handle MaxValue epochFix max epoch ci-approved core Kafka Broker storage Pull requests that target the storage module transactions Transactions and EOS
#21469 opened Feb 13, 2026 by artemlivshits Loading…
8
Add RetentionSizeInPercent and LocalRetentionSizeInPercent metrics for storage monitoring storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature triage PRs from the community
#21468 opened Feb 13, 2026 by manangupta111 Loading…
ProTip! Follow long discussions with comments:>50.