Skip to content

Pull requests: apache/kafka

New pull request New
1,096 Open 14,809 Closed
1,096 Open 14,809 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-15905 Restarts of MirrorCheckpointTask should not permanently i…
#15910 opened May 9, 2024 by edoardocomar Loading…
KAFKA-16695: Improve expired poll logging
consumer
#15909 opened May 9, 2024 by lianetm Loading…
2
MINOR: migrate DescribeConsumerGroupTest to use ClusterTestExtensions
#15908 opened May 9, 2024 by FrankYang0529 Loading…
3 tasks
KAFKA-16660: reduce the check interval to speedup DelegationTokenRequestsTest
#15907 opened May 9, 2024 by brandboat Loading…
3 tasks
1
KAFKA-16684: fix flaky DedicatedMirrorIntegrationTest
#15906 opened May 9, 2024 by johnnychhsu Loading…
3 tasks
2
MINOR: Add flag to read from specific partitions while checking consumer performance
#15905 opened May 9, 2024 by BOOTMGR Loading…
3 tasks
MINOR: fix LogValidatorTest#checkNonCompressed
#15904 opened May 9, 2024 by chia7712 Loading…
3 tasks
3
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
9
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
KAFKA-16691: [connect:transform] Support nested field paths on TimestampConverter
#15893 opened May 8, 2024 by jeqo Loading…
3 tasks
1
[DON'T SEE THIS PR] debug for thread leak
#15891 opened May 8, 2024 by chia7712 Loading…
3 tasks
1
KAFKA-16643 Fix chaos modifier
#15890 opened May 8, 2024 by gongxuanzhang Loading…
4
MINOR: Fix rate metric spikes
#15889 opened May 8, 2024 by emitskevich-blp Loading…
3 tasks
2
KAFKA-16264: Expose producer.id.expiration.check.interval.ms as dynamic broker configuration
#15888 opened May 8, 2024 by jeqo Loading…
3 tasks
2
KAFKA-15045: (KIP-924) New interfaces and stubbed utility classes for pluggable TaskAssignors.
#15887 opened May 8, 2024 by apourchet Loading…
3 tasks
23
KAFKA-16688: Use helper method to shutdown ExecutorService
#15886 opened May 8, 2024 by gaurav-narula Loading…
3 tasks
4
KAFKA-16686: Wait for given offset in TopicBasedRemoteLogMetadataManagerTest
#15885 opened May 7, 2024 by gaurav-narula Loading…
3
KAFKA-16679 merge unit test down to the class of integration test
#15884 opened May 7, 2024 by KevinZTW Loading…
3 tasks
9
MINOR: Rewrite OptimizedUniformAssignmentBuilder#assignStickyPartitions to improve performance
KIP-848
#15883 opened May 7, 2024 by dajac • Draft
3 tasks
KAFKA-10199: Handle assignment with new remove operation in state updater
#15882 opened May 7, 2024 by cadonna Loading…
3 tasks
8
ProTip! Adding no:label will show everything without a label.