Skip to content

/ kafka

New pull request New
775 Open 8,871 Closed
775 Open 8,871 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-10758: ProcessorTopology should only consider its own nodes when updating regex source topics
streams
#9648 opened Nov 24, 2020 by ableegoldman • Approved
5
KAFKA-10500: Remove thread
#9647 opened Nov 24, 2020 by wcarlson5 0 of 3
3
MINOR: Update snappy-java to 1.1.8.1
#9646 opened Nov 23, 2020 by ijuma 0 of 3
MINOR: Update build and test dependencies
#9645 opened Nov 23, 2020 by ijuma 0 of 3
3
KAFKA-10565: Only print console producer prompt with a tty
#9644 opened Nov 23, 2020 by tombentley
2
MINOR: Upgrade to Scala 2.13.4 and 2.12.13
#9643 opened Nov 23, 2020 by ijuma 0 of 3
1
MINOR: Merging WorkerTask constructor
#9642 opened Nov 23, 2020 by abc863377 • Approved
3
MINOR: Convert connect assignment schemas to use generated protocol
#9641 opened Nov 23, 2020 by chia7712 0 of 3
KAFKA-10283; Consolidate client-level and consumer-level assignment within ClientState
#9640 opened Nov 22, 2020 by highluck 0 of 3
1
KAFKA-10677; Complete fetches in purgatory immediately after resigning
#9639 opened Nov 22, 2020 by dengziming 0 of 3
MINOR; Remove duplicate update updateLeaderEndOffsetAndTimestamp
#9638 opened Nov 22, 2020 by dengziming
1
KAFKA-10756; Add missing unit test for `UnattachedState`
#9635 opened Nov 21, 2020 by dengziming
1
KAFKA-10702; Skip bookkeeping of empty transactions
#9632 opened Nov 20, 2020 by hachikuji 0 of 3
5
KAFKA-9672: Leader with ISR as a superset of replicas
#9631 opened Nov 20, 2020 by jsancio 0 of 3
3
KAFKA-10739; Replace EpochEndOffset with automated protocol
#9630 opened Nov 20, 2020 by dajac • Approved 0 of 3
5
KAFKA-10754: fix flaky tests by waiting kafka streams be in running state before assert
streams tests
#9629 opened Nov 20, 2020 by showuon 0 of 3
16
KAFKA-10747: Implement APIs for altering and describing IP connection rate quotas
#9628 opened Nov 20, 2020 by splett2 0 of 3
KAFKA-10746: Change to Warn logs when necessary to notify users
#9627 opened Nov 20, 2020 by showuon 0 of 3
1
KAFKA-10545: Create topic IDs and propagate to brokers
#9626 opened Nov 19, 2020 by jolshan 0 of 3
4
KAFKA-10655: wrap and catch exception for appendAsLeader failure
#9624 opened Nov 19, 2020 by abbccdda 0 of 3
KAFKA-10547; add topicId in MetadataResp
#9622 opened Nov 19, 2020 by dengziming 0 of 3
11
KAFKA-9892: Producer state snapshot needs to be forced to disk
#9621 opened Nov 19, 2020 by bristy
2
MINOR: Get rid of generic from FetchResponse
#9620 opened Nov 19, 2020 by chia7712 0 of 3
POC: fix task idling
streams
#9616 opened Nov 18, 2020 by vvcephei 0 of 3
KAFKA-10500: Add thread option
#9615 opened Nov 18, 2020 by wcarlson5 0 of 3
22
ProTip! Mix and match filters to narrow down what you’re looking for.
You can’t perform that action at this time.