Skip to content

Pull requests: apache/kafka

New pull request New
273 Open 21,151 Closed
273 Open 21,151 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-19831: Improved error handling in DefaultStateUpdater. (#20767)
#21438 opened Feb 9, 2026 by Nikita-Shupletsov Loading…
MINOR: Ensure CoordinatorRuntime does not throw synchronous exceptions when returning futures group-coordinator
#21437 opened Feb 9, 2026 by dajac Loading…
2
MINOR: Replace ConfiguredTopology with TopologyValidationResult group-coordinator performance
#21436 opened Feb 9, 2026 by lucasbru • Draft
5 tasks done
MINOR: Document that REMAIN_IN_GROUP is ignored with streams protocol small Small PRs streams
#21433 opened Feb 9, 2026 by lucasbru Loading…
KAFKA-19914: Move AlterPartitionManager to server module build Gradle build or GitHub Actions ci-approved core Kafka Broker performance triage PRs from the community
#21432 opened Feb 9, 2026 by joshua2519 Loading…
MINOR: Fix SSL certificate verification failure in system test worker provisioning small Small PRs tools triage PRs from the community
#21431 opened Feb 9, 2026 by tirthooo7 Loading…
EN-20096 Adding rocksdb upgrade and downgrade system test streams
#21430 opened Feb 8, 2026 by iit2009060 Loading…
1
KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module ci-approved clients consumer triage PRs from the community
#21429 opened Feb 8, 2026 by zooo-code Loading…
2
KAFKA-20150: Add Structurizr scaffolding for C4 Diagrams docs triage PRs from the community
#21428 opened Feb 8, 2026 by sujayopensource Loading…
MINOR: Fix Javadoc in coordinator-common group-coordinator small Small PRs
#21427 opened Feb 8, 2026 by majialoong Loading…
1
MINOR: Fix off-by-one in ShareCoordinatorShard snapshot update count ci-approved KIP-932 Queues for Kafka small Small PRs triage PRs from the community
#21426 opened Feb 8, 2026 by majialoong Loading…
KAFKA-20119: Clarify that Consumer#unsubscribe does not trigger auto-commit clients consumer small Small PRs triage PRs from the community
#21424 opened Feb 8, 2026 by TaiJuWu Loading…
1
KAFKA-19960: Close pending tasks on shutdown. (#21365) ci-approved streams
#21422 opened Feb 7, 2026 by Nikita-Shupletsov Loading…
2
KAFKA-19960: Close pending tasks on shutdown. (#21365) ci-approved streams
#21421 opened Feb 6, 2026 by Nikita-Shupletsov Loading…
3
KAFKA-20130: Move RecordValidationStats to storage module clients storage Pull requests that target the storage module
#21418 opened Feb 6, 2026 by clolov Loading…
2
KAFKA-20125: Improve the docs of dynamic-only configurations ci-approved core Kafka Broker small Small PRs
#21416 opened Feb 6, 2026 by jingjia88 Loading…
2
KAFKA-20099: Clarify how stream-time works in the docs docs small Small PRs triage PRs from the community
#21414 opened Feb 5, 2026 by AlexCSalinas Loading…
1
KAFKA-20127: Add new methods to StateSerdes streams
#21411 opened Feb 5, 2026 by frankvicky Loading…
17
KAFKA-19915: [1/3] Move LogAppendResult to server module core Kafka Broker
#21410 opened Feb 5, 2026 by clolov Loading…
2
KAFKA-20122: Create HeadersBytesStore streams
#21409 opened Feb 5, 2026 by frankvicky Loading…
13
KAFKA-20121: Create ValueTimestampHeaders and its serializer/deserializer ci-approved kip Requires or implements a KIP streams
#21408 opened Feb 5, 2026 by frankvicky Loading…
70
KAFKA-15899: [2/2] Move kafka.security package from core to server module build Gradle build or GitHub Actions ci-approved core Kafka Broker tools triage PRs from the community
#21407 opened Feb 5, 2026 by clolov Loading…
KAFKA-20124 Move LogCleanerLagIntegrationTest to storage module core Kafka Broker storage Pull requests that target the storage module tests Test fixes (including flaky tests) triage PRs from the community
#21406 opened Feb 5, 2026 by see-quick Loading…
MINOR: Add test for ConfigDef.convertToString with null type ci-approved clients small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#21402 opened Feb 5, 2026 by majialoong Loading…
Minor: Preserve user-provided acks config without mutation clients producer small Small PRs triage PRs from the community
#21400 opened Feb 4, 2026 by anupamalok Loading…
1
ProTip! Add no:assignee to see everything that’s not assigned.