Skip to content

Pull requests: apache/kafka

New pull request New
460 Open 22,370 Closed
460 Open 22,370 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-20829: Throttle StreamThread shutdown rebalance enforcement to avoid log flood small Small PRs streams triage PRs from the community
#22917 opened Jul 23, 2026 by SouquieresAdam Contributor Loading…
3 tasks
[4.3] KAFKA-20726: Don't reuse the BufferSupplier in kraft state machine
#22915 opened Jul 22, 2026 by tzy-0x7cf Loading…
[4.2] KAFKA-20726: Don't reuse the BufferSupplier in kraft state machine
#22914 opened Jul 22, 2026 by tzy-0x7cf Loading…
[4.1] KAFKA-20726: Don't reuse the BufferSupplier in kraft state machine
#22913 opened Jul 22, 2026 by tzy-0x7cf Loading…
KAFKA-20356: make clusterId in-memory thread safe via future core Kafka Broker kraft triage PRs from the community
#22911 opened Jul 22, 2026 by kevin-wu24 Contributor • Draft
KAFKA-20819: Fail requests when state updater thread dies streams triage PRs from the community
#22910 opened Jul 22, 2026 by arnabnandy7 Loading…
4
KAFKA-20826: Fix EndToEndLatencyTest#testInvalidRecordHeaderValue ci-approved small Small PRs tests Test fixes (including flaky tests) tools triage PRs from the community
#22909 opened Jul 22, 2026 by majialoong Contributor Loading…
KAFKA-20828: Derive client throttling from response schema ci-approved clients small Small PRs
#22908 opened Jul 22, 2026 by arnabnandy7 Loading…
8
MINOR: Move SaslClientsWithInvalidCredentialsTest to clients integration tests ci-approved clients core Kafka Broker tests Test fixes (including flaky tests) triage PRs from the community
#22907 opened Jul 22, 2026 by Parkerhiphop Contributor Loading…
KAFKA-20723: Bound decompression memory in ShareGroupDLQRecordFetcher ci-approved clients core Kafka Broker KIP-932 Queues for Kafka
#22905 opened Jul 22, 2026 by smjn Collaborator Loading…
4
MINOR: Add AdminClient stale leader close grace period test ci-approved clients small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#22904 opened Jul 22, 2026 by Parkerhiphop Contributor Loading…
MINOR: Set StreamThread to non-daemon status small Small PRs streams
#22902 opened Jul 21, 2026 by bbejeck Member Loading…
4
Refactor - Consolidate process-and-verify helpers, PART-2 ci-approved streams tests Test fixes (including flaky tests) triage PRs from the community
#22901 opened Jul 21, 2026 by muralibasani Contributor Loading…
1
KAFKA-20825 Fix native image startup with share group DLQ manager ci-approved core Kafka Broker KIP-932 Queues for Kafka small Small PRs triage PRs from the community
#22900 opened Jul 21, 2026 by dino2895 Contributor Loading…
2
KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable (2/2) build Gradle build or GitHub Actions ci-approved clients connect consumer core Kafka Broker producer streams tools triage PRs from the community
#22897 opened Jul 21, 2026 by frankvicky Contributor Loading…
7
KAFKA-16262: Add IQv2 to Kafka Streams documentation docs triage PRs from the community
#22896 opened Jul 21, 2026 by Jess668 Contributor • Draft
KFK-19871: Add Runtime interface streams triage PRs from the community
#22895 opened Jul 21, 2026 by sebastienviale Contributor Loading…
KAFKA-20821: DeleteRecordsCommand exits non-zero on per-partition errors small Small PRs tools triage PRs from the community
#22894 opened Jul 21, 2026 by viktorsomogyi Contributor Loading…
KAFKA-20820: make symlinked log.dirs possible when on JDK17 kraft small Small PRs triage PRs from the community
#22893 opened Jul 21, 2026 by harmadasg Contributor Loading…
KAFKA-20736: Close empty share sessions safely ci-approved clients consumer KIP-932 Queues for Kafka
#22888 opened Jul 20, 2026 by AndrewJSchofield Member Loading…
2
KAFKA-20813 Add Podman support to Docker image build tests ci-approved docker Official Docker image small Small PRs
#22886 opened Jul 20, 2026 by dino2895 Contributor Loading…
6
KAFKA-20553: Remove clients-integration-tests dependency on core test output build Gradle build or GitHub Actions ci-approved clients core Kafka Broker
#22884 opened Jul 20, 2026 by majialoong Contributor Loading…
2
KAFKA-20816: Add support for CIDR into Authorizer.authorizeByResourceType build Gradle build or GitHub Actions ci-approved clients kraft small Small PRs
#22883 opened Jul 20, 2026 by see-quick Contributor Loading…
6
KAFKA-20682: Document IQv2 headers-aware queries (KIP-1356) docs small Small PRs triage PRs from the community
#22882 opened Jul 20, 2026 by Jess668 Contributor • Draft
MINOR: Cache SASL principal per authentication clients small Small PRs triage PRs from the community
#22880 opened Jul 20, 2026 by nandini12396 Contributor Loading…
ProTip! Type g i on any issue or pull request to go back to the issue listing page.