Skip to content

Pull requests: apache/kafka

New pull request New
243 Open 19,424 Closed
243 Open 19,424 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
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

jprnt02 clients consumer producer triage PRs from the community
#19672 opened May 11, 2025 by aryojp Loading…
jprnt01/streams/examples/src/main/java/org/apache/kafka/streams/exampl… build Gradle build or GitHub Actions clients connect consumer core Kafka Broker dependencies Pull requests that update a dependency file docker Official Docker image generator RPC and Record code generator KIP-932 Queues for Kafka kraft mirror-maker-2 performance producer storage Pull requests that target the storage module streams tiered-storage Related to the Tiered Storage feature tools transactions Transactions and EOS triage PRs from the community
#19671 opened May 11, 2025 by aryojp Loading…
KAFKA-13555: Use input partitions for StickyTaskAssignor [WIP] streams triage PRs from the community
#19670 opened May 10, 2025 by lorcanj • Draft
1
MINOR: clean KafkaConsumer tests clients consumer tests Test fixes (including flaky tests)
#19669 opened May 10, 2025 by mjsax Loading…
42
KAFKA-19255: KRaft request manager should support one in-flight request per request type kraft triage PRs from the community
#19668 opened May 9, 2025 by kevin-wu24 Loading…
KAFKA-19116, KAFKA-19258: Handling share group member change events core Kafka Broker KIP-932 Queues for Kafka triage PRs from the community
#19666 opened May 9, 2025 by apoorvmittal10 • Draft
[KAFKA-18681] Created GetReplicaLogInfo* RPCs ci-approved clients core Kafka Broker
#19664 opened May 8, 2025 by josefk31 Loading…
2
MINOR: Move TxnTransitMetadata to transaction-coordinator ci-approved core Kafka Broker transactions Transactions and EOS
#19662 opened May 8, 2025 by yunchipang Loading…
6
MINOR; Remove cast for Records' slice clients core Kafka Broker
#19661 opened May 8, 2025 by jsancio Loading…
23
KAFKA-19253: Improve metadata handling for share version using feature listeners (1/N) ci-approved core Kafka Broker KIP-932 Queues for Kafka triage PRs from the community
#19659 opened May 8, 2025 by adixitconfluent Loading…
[KAFKA-18345] Prevent deadlocked elections ci-approved kraft small Small PRs
#19658 opened May 7, 2025 by ahuang98 Loading…
13
txnProducer.abortTransaction() API should not return abortable exception ci-approved clients producer small Small PRs
#19656 opened May 7, 2025 by k-raina Loading…
1
KAFKA-19042: [8/N] Move BaseConsumerTest, SaslPlainPlaintextConsumerTest to client-integration-tests module clients core Kafka Broker tests Test fixes (including flaky tests)
#19651 opened May 6, 2025 by m1a2st Loading…
8
KAFKA-19244: Add support for kafka-streams-groups.sh options (delete group, offset-related APIs) [1/2] ci-approved clients KIP-1071 PRs related to KIP-1071 streams tools
#19646 opened May 5, 2025 by aliehsaeedii Loading…
4
[KAFKA-18905] Reduce ReassignPartitionTest flakiness small Small PRs tests Test fixes (including flaky tests)
#19644 opened May 5, 2025 by josefk31 Loading…
4
KAFKA-19231: Handle fetch request when share session cache is full ci-approved clients core Kafka Broker KIP-932 Queues for Kafka
#19637 opened May 5, 2025 by chirag-wadhwa5 Loading…
15
Refactored DescribeTopicPartitionsRequestHandler: Improve readability and add code documentation core Kafka Broker triage PRs from the community
#19636 opened May 4, 2025 by keemsisi Loading…
KAFKA-19234: broker should return UNAUTHORIZATION error for non-existing topic in produce request ci-approved core Kafka Broker
#19635 opened May 4, 2025 by FrankYang0529 Loading…
51
KAFKA-18695: Remove quorum=kraft and kip932 from all integration tests ci-approved core Kafka Broker tests Test fixes (including flaky tests) tools
#19633 opened May 4, 2025 by mingyen066 Loading…
12
KAFKA-19242: Fix commit bugs caused by race condition during rebalancing. ci-approved clients consumer small Small PRs
#19631 opened May 4, 2025 by chickenchickenlove Loading…
19
KAFKA-19145: Move LeaderEndPoint to Server module ci-approved core Kafka Broker performance
#19630 opened May 3, 2025 by YutaLin Loading…
45
(WIP)KAFKA-19203 Replace ApiError#exception by Error#exception for KafkaAdminClient ci-approved clients small Small PRs
#19623 opened May 2, 2025 by jim0987795064 Loading…
KAFKA-18847: Refactor OAuth layer to improve reusability 1/N ci-approved clients tools
#19622 opened May 2, 2025 by kirktrue Loading…
39
KAFKA-18996 Expose addReadOnlyStateStore in DSL (StreamsBuilder) needs-attention streams triage PRs from the community
#19621 opened May 2, 2025 by siddharthaDevineni Loading…
1
KAFKA-19097: Fix assertEquals arguement order in InternalStreamsBuilderTest ci-approved streams
#19615 opened May 1, 2025 by shelbysash Loading…
2
ProTip! Type g p on any issue or pull request to go back to the pull request listing page.