Skip to content

/ kafka

New pull request New
913 Open 9,994 Closed
913 Open 9,994 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels.
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
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀
KAFKA-12158: Better return type of RaftClient.scheduleAppend
#10909 opened Jun 20, 2021 by dengziming
KAFKA-10000: Exactly-once support for source connectors
#10907 opened Jun 19, 2021 by C0urante 0 of 3
1
KAFKA-12835: Topic IDs can mismatch on brokers (after interbroker protocol version update)
#10906 opened Jun 18, 2021 by jolshan 0 of 3
1
MINOR: Replace EasyMock and PowerMock with Mockito in WorkerGroupMemberTest
#10904 opened Jun 18, 2021 by tang7526 0 of 3
1
[WIP] KAFKA-12473: make "cooperative-sticky, range" as the default assignor
#10903 opened Jun 18, 2021 by showuon 0 of 3
KAFKA-12967; KRaft broker should forward DescribeQuorum to controller
#10900 opened Jun 17, 2021 by hachikuji 0 of 3
5
KAFKA-12952 Adding Delimeters to Metadata Snapshot File
#10899 opened Jun 17, 2021 by niket-goel • Draft
20
MINOR: Reduced severity for "skipping records" falling out of time windows
#10897 opened Jun 17, 2021 by xdgrulez
KAFKA-12964: Collect and rename snapshot files prior to async deletion.
#10896 opened Jun 17, 2021 by gardnervickers
9
KAFKA-12890; Consumer group stuck in CompletingRebalance (2.8)
#10895 opened Jun 17, 2021 by dajac 0 of 3
KAFKA-12951: restore must terminate for tx global topic
streams
#10894 opened Jun 17, 2021 by mjsax • Approved 0 of 3
14
KAFKA-12909: add missing tests
streams
#10893 opened Jun 17, 2021 by mjsax
[WIP] New Admin API for deleteTopics
#10892 opened Jun 17, 2021 by jolshan • Draft 0 of 3
1
KAFKA-12891: KIP-749 Add --files and --file-separator options to the ConsoleProducer (WIP)
#10889 opened Jun 16, 2021 by wenbingshen 0 of 3
2
MINOR: Refactor the MetadataCache interface
kip-500
#10887 opened Jun 16, 2021 by cmccabe
MINOR: replace deprecated exactly_once_beta into exactly_once_v2
#10884 opened Jun 15, 2021 by showuon 0 of 3
2
KAFKA-12949: TestRaftServer's scala.MatchError: null on test-kraft-server-start.sh
#10883 opened Jun 15, 2021 by IgnacioAcunaF 0 of 3
11
KAFKA-12947 Replace EasyMock and PowerMock with Mockito for StreamsMe…
#10881 opened Jun 14, 2021 by wycccccc 0 of 3
2
MINOR: Fix unsafe access to AbstractCoordinator.state
#10879 opened Jun 14, 2021 by dajac 0 of 3
2
KAFKA-12898; Owned partitions in the subscription must be sorted
#10878 opened Jun 14, 2021 by dajac 0 of 3
5
KAFKA-12925: adding presfixScan operation for missed implementations
streams
#10877 opened Jun 13, 2021 by vamossagar12 0 of 3
4
KAFKA-12843: KIP-740 follow up: clean up TaskMetadata
#10876 opened Jun 13, 2021 by socutes
3
KAFKA-12844: KIP-740 follow up: clean up TaskId
#10875 opened Jun 13, 2021 by socutes
2
KAFKA-7360 Fixed code snippet
#10873 opened Jun 13, 2021 by vijaykriishna 0 of 3
KAFKA-10546: Deprecate old PAPI
streams
#10869 opened Jun 11, 2021 by vvcephei • Approved 0 of 3
@vvcephei
33
ProTip! Type g p on any issue or pull request to go back to the pull request listing page.