Skip to content

Pull requests: apache/kafka

New pull request New
308 Open 21,304 Closed
308 Open 21,304 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-20205: Refactor serialization and deserialization code for *WithHeaders types streams triage PRs from the community
#21626 opened Mar 4, 2026 by zheguang Loading…
fix: replace printStackTrace() with proper logging in KafkaStreamsNamedTopologyWrapper small Small PRs streams triage PRs from the community
#21625 opened Mar 4, 2026 by Senrian Loading…
KAFKA-20241: Bump jackson to 2.21.1 build Gradle build or GitHub Actions ci-approved dependencies Pull requests that update a dependency file small Small PRs triage PRs from the community
#21621 opened Mar 3, 2026 by averemee-si Loading…
2
MINOR: Update collections with Java 11 equivalents in generator, exam… ci-approved generator RPC and Record code generator performance small Small PRs triage PRs from the community
#21620 opened Mar 3, 2026 by see-quick Loading…
KAFKA-20247: Controller registration needs to retry after request timeout ci-approved core Kafka Broker small Small PRs
#21619 opened Mar 3, 2026 by kevin-wu24 Loading…
@jsancio
5
KAFKA-14597: Fix record-e2e-latency to include processing delay at terminal nodes ci-approved small Small PRs streams
#21618 opened Mar 3, 2026 by praiyani6789 Loading…
KAFKA-17895: Add num-keys metric for in-memory state stores ci-approved kip Requires or implements a KIP streams
#21617 opened Mar 3, 2026 by ezhou413 Loading…
KAFKA-20239: Document Kafka ACLS required for Connect ci-approved docs
#21615 opened Mar 2, 2026 by dalelane Loading…
7
kAFKA-9651:Handle edge case when partition metadata contains zero partitions clients producer small Small PRs streams
#21609 opened Mar 1, 2026 by nileshkumar3 Loading…
8
refactor: simplify code core Kafka Broker kraft small Small PRs triage PRs from the community
#21608 opened Mar 1, 2026 by spotlesscoder Loading…
KAFKA-19863: Add documentation on how to implement a custom exception(with ref to DLQ) docs small Small PRs triage PRs from the community
#21606 opened Feb 28, 2026 by Rajarshi-Misra Loading…
1
Address KAFKA-13819 small Small PRs streams triage PRs from the community
#21605 opened Feb 28, 2026 by dubeyKartikay Loading…
KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. clients consumer streams triage PRs from the community
#21603 opened Feb 28, 2026 by chickenchickenlove Loading…
2
KAFKA-20235: Replace System.out.println with proper logger for missing property file warning clients small Small PRs triage PRs from the community
#21602 opened Feb 28, 2026 by highluck Loading…
KAFKA-17939: Make Bytes part of the public API (KIP-1247) build Gradle build or GitHub Actions ci-approved clients performance streams
#21601 opened Feb 27, 2026 by siddharthaDevineni Loading…
3 tasks
35
KAFKA-20158: Enable SessionStore with headers in DSL streams
#21600 opened Feb 27, 2026 by bbejeck Loading…
20
KAFKA-20221: Enable TimestampedWindowStoreWithHeaders in DSL (1/N) streams
#21599 opened Feb 27, 2026 by frankvicky • Draft
3
KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls ci-approved
#21598 opened Feb 27, 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] ci-approved clients group-coordinator performance
#21594 opened Feb 26, 2026 by lucliu1108 Loading…
@lucasbru
8
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-20220: Enable TimestampedKVStoreWithHeaders in DSL (4/N) streams triage PRs from the community
#21590 opened Feb 26, 2026 by aliehsaeedii Loading…
MINOR: Keep pendingTask as WakeupFuture if currentTask is completed already. clients consumer small Small PRs tools
#21586 opened Feb 26, 2026 by Nikita-Shupletsov • Draft
15
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
#21584 opened Feb 25, 2026 by unknowntpo Loading…
2
ProTip! no:milestone will show everything without a milestone.