Skip to content

Pull requests: apache/kafka

New pull request New
275 Open 21,141 Closed
275 Open 21,141 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

EN-20096 Adding rocksdb upgrade and downgrade system test streams triage PRs from the community
#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…
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 triage PRs from the community
#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-20129: Fix server error when appending or subtracting a non-existent config key core Kafka Broker small Small PRs triage PRs from the community
#21425 opened Feb 8, 2026 by DL1231 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…
KAFKA-19960: Close pending tasks on shutdown. (#21365)
#21423 opened Feb 7, 2026 by Nikita-Shupletsov Loading…
1
KAFKA-19960: Close pending tasks on shutdown. (#21365)
#21422 opened Feb 7, 2026 by Nikita-Shupletsov Loading…
1
KAFKA-19960: Close pending tasks on shutdown. (#21365)
#21421 opened Feb 6, 2026 by Nikita-Shupletsov Loading…
1
KAFKA-20130: Move RecordValidationStats to storage module small Small PRs 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-20128: Add missing TimestampType to java doc and move non-public classes to internal subpackage build Gradle build or GitHub Actions clients connect consumer core Kafka Broker generator RPC and Record code generator group-coordinator KIP-932 Queues for Kafka kraft performance producer storage Pull requests that target the storage module streams tiered-storage Related to the Tiered Storage feature tools transactions Transactions and EOS
#21412 opened Feb 5, 2026 by lianetm Loading…
11
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…
65
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…
KAFKA-20115: Group coordinator fails to unload metadata when no longer leader or follower clients small Small PRs tests Test fixes (including flaky tests)
#21403 opened Feb 5, 2026 by brandboat 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
KAFKA-20097: Populate topicId for existing topics in CreateTopics response core Kafka Broker kraft triage PRs from the community
#21399 opened Feb 4, 2026 by Shally-Katariya Loading…
KAFKA-20096: Add documentation about the incompatibility of RocksDB file format ci-approved docs small Small PRs streams
#21397 opened Feb 4, 2026 by iit2009060 Loading…
6
ProTip! Type g p on any issue or pull request to go back to the pull request listing page.