Skip to content

/ kafka

New pull request New
760 Open 8,813 Closed
760 Open 8,813 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
👍 👎 😄 🎉 😕 ❤️ 🚀 👀
MINOR: optimize lock operation
#9575 opened Nov 7, 2020 by dengziming
MINOR: KIP-497 Not start Controller2ChannelManager when we are using zookeeper to notify isr change
#9574 opened Nov 7, 2020 by dengziming
1
KAFKA-10693: Close quota managers created in tests
#9573 opened Nov 6, 2020 by splett2 0 of 3
KAFKA-10500: Thread Cache Resizes
#9572 opened Nov 6, 2020 by wcarlson5 0 of 3
2
KAFKA-9274: Handle TimeoutException on commit
streams
#9570 opened Nov 6, 2020 by mjsax
7
KAFKA-10687: make ProduceRespone only returns INVALID_PRODUCER_EPOCH
#9569 opened Nov 6, 2020 by abbccdda • Approved 0 of 3
3
KAFKA-10689: fix windowed FKJ topology and put checks in assignor to avoid infinite loops
#9568 opened Nov 6, 2020 by ableegoldman
KAFKA-10618: Update to Uuid class
#9566 opened Nov 5, 2020 by jolshan 0 of 3
1
KAFKA-10667: add timeout for forwarding requests
#9564 opened Nov 5, 2020 by abbccdda 0 of 3
2
KAFKA-10684; Avoid additional envelope copies during network transmission
#9563 opened Nov 5, 2020 by hachikuji 0 of 3
18
KAFKA-10345: Add ZK-notification based update for trust/key store paths
#9560 opened Nov 5, 2020 by abbccdda 0 of 3
1
KAFKA-10342: migrate remaining RPCs to forwarding
#9558 opened Nov 5, 2020 by abbccdda 0 of 3
MINOR: Update jetty to 9.4.33
#9556 opened Nov 4, 2020 by niteshmor 0 of 3
3
KAFKA-10427: Fetch snapshot
#9553 opened Nov 3, 2020 by jsancio 0 of 3
KAFKA-10656: Log the feature flags received by the client
#9552 opened Nov 3, 2020 by tombentley
1
KIP-145: Add SMTs, HeaderFrom, DropHeaders and InsertHeader
#9549 opened Nov 3, 2020 by tombentley
1
Disable inlining of Scala library methods.
#9548 opened Nov 3, 2020 by olafurpg 3 of 3
8
KAFKA-9630; Migrate OffsetsForLeaderEpochRequest/Response to the auto-generated protocol
#9547 opened Nov 3, 2020 by dajac • Draft 0 of 3
2
[mm2] Allow Checkpoints for consumers using static partition assignments
#9545 opened Nov 3, 2020 by scanterog
2
KAFKA-10675: Add schema name to ConnectSchema.validateValue() error message
connect
#9541 opened Nov 2, 2020 by Iskuskov 0 of 3
KAFKA-10634: Adding LeaderId to Voters list in LeaderChangeMessage
#9539 opened Oct 31, 2020 by vamossagar12 0 of 3
8
Show log end offset during truncation to help estimate data loss during ULE
#9533 opened Oct 29, 2020 by gitlw 0 of 3
KAFKA-10661; Add new resigned state for graceful shutdown/initialization
#9531 opened Oct 29, 2020 by hachikuji 0 of 3
10
MINOR: avoid unnecessary conversion and tuple when updating error met…
#9527 opened Oct 29, 2020 by chia7712 0 of 3
1
KAFKA-10525: Emit JSONs with new auto-generated schema
#9526 opened Oct 29, 2020 by anatasiavela
77
ProTip! Type g p on any issue or pull request to go back to the pull request listing page.
You can’t perform that action at this time.