Skip to content

Pull requests: apache/kafka

New pull request New
307 Open 21,276 Closed
307 Open 21,276 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

MINOR: Moved resetting checkpointed offsets after stopping KS when the new protocol is used. small Small PRs streams tests Test fixes (including flaky tests)
#21597 opened Feb 26, 2026 by Nikita-Shupletsov Loading…
1
KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls ci-approved
#21596 opened Feb 26, 2026 by kirktrue Loading…
KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (5/N) streams triage PRs from the community
#21595 opened Feb 26, 2026 by aliehsaeedii Loading…
KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [3/N] clients group-coordinator performance triage PRs from the community
#21594 opened Feb 26, 2026 by lucliu1108 Loading…
MINOR: Fix GroupConfigManager.validate() to include all group type defaults ci-approved group-coordinator small Small PRs triage PRs from the community
#21593 opened Feb 26, 2026 by majialoong Loading…
1
KAFKA-20232: Fix WakeupException in awaitMetadataUpdate() clients consumer small Small PRs triage PRs from the community
#21592 opened Feb 26, 2026 by Baisang Loading…
KAFKA-20229: Batch offset translation in RemoteClusterUtils connect
#21591 opened Feb 26, 2026 by mimaison Loading…
KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (4/N) streams triage PRs from the community
#21590 opened Feb 26, 2026 by aliehsaeedii Loading…
MINOR: Made shutdown request more robust. small Small PRs tools
#21586 opened Feb 26, 2026 by Nikita-Shupletsov Loading…
7
fix: replace 12 bare except clauses with except Exception docker Official Docker image small Small PRs triage PRs from the community
#21585 opened Feb 26, 2026 by haosenwang1018 Loading…
KAFKA-20166: Ensure consumer with auto-commit enabled commits offsets before switching partitions ci-approved clients consumer triage PRs from the community
#21584 opened Feb 25, 2026 by unknowntpo Loading…
MINOR: Upgrade dependencies versions for bouncycastle and jgit-related libraries build Gradle build or GitHub Actions small Small PRs triage PRs from the community
#21583 opened Feb 25, 2026 by dejan2609 Loading…
KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (3/N) streams triage PRs from the community
#21582 opened Feb 25, 2026 by aliehsaeedii Loading…
KAFKA-20134: Implement TimestampedWindowStoreWithHeaders (N/N) streams
#21581 opened Feb 25, 2026 by frankvicky Loading…
15
KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (2/N) streams triage PRs from the community
#21580 opened Feb 25, 2026 by aliehsaeedii Loading…
KAFKA-20167 Introduce CloseOptions.DEFAULT for Kafka Streams (WIP) clients consumer streams triage PRs from the community
#21579 opened Feb 25, 2026 by m1a2st Loading…
KAFKA-20212: Manage offsets in RocksDBStore streams
#21578 opened Feb 25, 2026 by eduwercamacaro Loading…
13
KAFKA-19562: Replace hand-written AbortedTxn with generated protocol clients core Kafka Broker storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature tools triage PRs from the community
#21577 opened Feb 25, 2026 by mingyen066 Loading…
KAFKA-19149: Add KIP-877 support to MirrorMaker connect mirror-maker-2
#21576 opened Feb 25, 2026 by mimaison Loading…
1
KAFKA-20178 Move LogCleanerIntegrationTest from core to storage ci-approved core Kafka Broker storage Pull requests that target the storage module tests Test fixes (including flaky tests)
#21575 opened Feb 25, 2026 by see-quick Loading…
2
KAFKA-19830 [1/N]: refactor KafkaRaftClient to use event-based scheduling core Kafka Broker kraft triage PRs from the community
#21574 opened Feb 25, 2026 by kevin-wu24 Loading…
KAFKA-20204: Remove partition-level ExpiresPerSec metrics when the broker no longer owns the partition core Kafka Broker storage Pull requests that target the storage module triage PRs from the community
#21573 opened Feb 25, 2026 by DL1231 Loading…
KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (1/N) ci-approved streams
#21572 opened Feb 24, 2026 by aliehsaeedii Loading…
3
KAFKA-20158 RocksDB session stores with headers support (4/N) streams
#21571 opened Feb 24, 2026 by bbejeck Loading…
6
MINOR: Move KRaftMetadataCachePublisher to metadata module and convert to Java core Kafka Broker kraft small Small PRs triage PRs from the community
#21570 opened Feb 24, 2026 by MahsaSeifikar Loading…
ProTip! Mix and match filters to narrow down what you’re looking for.