Skip to content

Pull requests: apache/kafka

New pull request New
1,095 Open 14,825 Closed
1,095 Open 14,825 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Milestones
Filter by milestone
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

KAFKA-16669: Remove extra collection copy when generating DescribeAclsResource
#15924 opened May 11, 2024 by chiacyu Loading…
2
KAFKA-16703: Close serverChannel in SocketServer if unable to bind to a port
#15923 opened May 10, 2024 by gharris1727 Loading…
3 tasks
2
KAFKA-16702: Fix producer leaks in KafkaLog4jAppenderTest
tests Test fixes (including flaky tests)
#15922 opened May 10, 2024 by gharris1727 Loading…
3 tasks
1
MINOR: Add classic member session timeout to ClassicMemberMetadata
KIP-848
#15921 opened May 10, 2024 by dongnuo123 Loading…
3 tasks
KAFKA-15045: (KIP-924 pt. 2) Implement ApplicationState and KafkaStreamsState
#15920 opened May 10, 2024 by apourchet Loading…
3 tasks
10
KAFKA-16699: Have Streams treat InvalidPidMappingException like a ProducerFencedException
#15919 opened May 10, 2024 by wcarlson5 Loading…
3 tasks
1
KAFKA-16667 Avoid stale read in KRaftMigrationDriver
#15918 opened May 10, 2024 by mumrah Loading…
MINOR: rewrite TopicBasedRemoteLogMetadataManagerTest by ClusterTestE…
#15917 opened May 10, 2024 by chia7712 Loading…
3 tasks
8
KAFKA-16654:Refactor kafka.test.annotation.Type and ClusterTestExtensions
#15916 opened May 10, 2024 by TaiJuWu Loading…
3 tasks
6
Increasing timeout for wait_for_loggers to 30s
#15915 opened May 10, 2024 by vamossagar12 • Draft
MINOR: Upgrade scala-logging to 3.9.5
#15914 opened May 10, 2024 by viktorsomogyi Loading…
3 tasks
1
Add demo template for transactional client
#15913 opened May 9, 2024 by k-raina • Draft
MINOR; Validate at least one control record
KIP-853 kraft
#15912 opened May 9, 2024 by jsancio Loading…
3 tasks
10
KAFKA-16696: Removed the in-memory implementation of RSM and RLMM
tiered-storage Pull requests associated with KIP-405 (Tiered Storage)
#15911 opened May 9, 2024 by kamalcph Loading…
3 tasks
9
KAFKA-15905 Restarts of MirrorCheckpointTask should not permanently i…
mirror-maker-2
#15910 opened May 9, 2024 by edoardocomar Loading…
3
KAFKA-16695: Improve expired poll logging
consumer
#15909 opened May 9, 2024 by lianetm Loading…
19
MINOR: migrate DescribeConsumerGroupTest to use ClusterTestExtensions
#15908 opened May 9, 2024 by FrankYang0529 Loading…
3 tasks
MINOR: Add flag to read from specific partitions while checking consumer performance
#15905 opened May 9, 2024 by BOOTMGR Loading…
3 tasks
KAFKA-16694: Remove Rack Awareness Code from the Server Side Assignors
KIP-848
#15903 opened May 9, 2024 by rreddy-22 Loading…
KAFKA-16663: cancel write timeout TimerTask on successful event completion
KIP-848
#15902 opened May 8, 2024 by jeffkbkim Loading…
3 tasks
3
Improve code example for using a transactional KafkaProducer
#15901 opened May 8, 2024 by matthiaskraaz Loading…
[MINOR] Renaming created to unassigned in IncrementalCooperativeAssignor#performTaskAssignment
connect
#15898 opened May 8, 2024 by vamossagar12 Loading…
KAFKA-16677: Replace ClusterType#ALL and ClusterType#DEFAULT by Array
#15897 opened May 8, 2024 by FrankYang0529 Loading…
3 tasks
44
KAFKA-10199: Remove queue-based remove from state updater
#15896 opened May 8, 2024 by cadonna Loading…
3 tasks
1
KAFKA-10199: Shutdown with new remove operation in state updater
#15894 opened May 8, 2024 by cadonna Loading…
3 tasks
10
ProTip! Filter pull requests by the default branch with base:trunk.