Skip to content

/ kafka

New pull request New
758 Open 8,425 Closed
758 Open 8,425 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: use the link of JDK 11 to replace the dynamic url when buildin…
#9185 opened Aug 15, 2020 by chia7712 0 of 3
KAFKA-8033; Wait for NoOffsetForPartitionException in testFetchInvalidOffset
#9184 opened Aug 14, 2020 by rajinisivaram • Approved 0 of 3
1
KAFKA-10404; Use higher poll timeout to avoid rebalance in testCoordinatorFailover
#9183 opened Aug 14, 2020 by rajinisivaram 0 of 3
KAFKA-10403 Replace scala collection by java collection in generating…
#9182 opened Aug 14, 2020 by chia7712 0 of 3
3
KAFKA-9516; Increase timeout in testNonBlockingProducer to make it more reliable
#9181 opened Aug 14, 2020 by rajinisivaram • Approved 0 of 3
1
MINOR: corrected unit tests
#9180 opened Aug 14, 2020 by sanketfajage
1
KAFKA-10390: Remove ignore case option when grep process info to be more specific
#9179 opened Aug 14, 2020 by showuon 0 of 3
1
KAFKA-8362: fix the old checkpoint won't be removed after alter log dir
#9178 opened Aug 14, 2020 by showuon 0 of 3
1
KAFKA-9924: Add RocksDB metric num-entries-active-mem-table
#9177 opened Aug 13, 2020 by cadonna
1
Allow replace all for RegexRouter
#9176 opened Aug 13, 2020 by carlos-verdes 1 of 3
KAFKA-10395: relax output topic check in TTD to work with dynamic routing
#9174 opened Aug 13, 2020 by ableegoldman
8
KAFKA-10387: Fix inclusion of transformation configs when topic creation is enabled in Connect
#9172 opened Aug 12, 2020 by kkonstantine • Approved 0 of 3
12
MINOR: the scheduler used to perform rebalance should have thread prefix
#9169 opened Aug 12, 2020 by chia7712 0 of 3
1
KAFKA-9941;WorkerSinkTask：When a record triggers a RetriableException and the retry is processed successfully, its offset does not commit.
#9167 opened Aug 12, 2020 by aluode99 3 of 3
MINOR: refactor Log to get rid of "return" in nested anonymous function
#9162 opened Aug 11, 2020 by chia7712 0 of 3
11
KAFKA-10385 - Remove no print stat when on detailed stat mode on Consumer Perf
#9161 opened Aug 11, 2020 by sebadiaz
2
KAFKA-10378: change jacksonDatabind as compile dependency for clients project
#9159 opened Aug 11, 2020 by showuon 0 of 3
2
Update for KIP-450 to handle early records
#9157 opened Aug 10, 2020 by lct45 0 of 3
KAFKA-10077: Filter downstream of state-store results in spurious tombstones
#9156 opened Aug 10, 2020 by big-andy-coates 0 of 3
1
MINOR KAFKA-10382 - MockProducer is not ThreadSafe, ideally it should be as the implementation it mocks is
#9154 opened Aug 10, 2020 by astubbs
KAFKA-9839; Broker should accept control requests with newer broker epoch
#9152 opened Aug 10, 2020 by viktorsomogyi 0 of 3
KAFKA-9839; Broker should accept control requests with newer broker epoch
#9151 opened Aug 10, 2020 by viktorsomogyi 0 of 3
KAFKA-9839; Broker should accept control requests with newer broker epoch
#9150 opened Aug 10, 2020 by viktorsomogyi 0 of 3
2
KAFKA-10340: improve the logging to help user know what is going on
#9149 opened Aug 10, 2020 by showuon 0 of 3
2
KAFKA-10379: Implement the KIP-478 StreamBuilder#addGlobalStore()
streams
#9148 opened Aug 10, 2020 by vvcephei 0 of 3
31
ProTip! Follow long discussions with comments:>50.
You can’t perform that action at this time.