Apache Kafka

Settings | Report Duplicate

17

I Use This!

Very High Activity

Commits : Listings

Analyzed 1 day ago. based on code collected 1 day ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Jun 06, 2024 — Jun 06, 2025 Showing page 524 of 530 Search / Filter on:
enable shallow iterator in ByteBufferMessageSet to allow mirroing data without decompression; patched by Jun Rao; reviewed by Joel Koshy; KAFKA-315	Jun Rao	More...				about 13 years ago
CallbackHandler.afterDequeuingExistingData is not called during event queue timeout; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-326	Jun Rao	More...				about 13 years ago
SyncProducer does not correctly timeout; patched by Prashanth Menon; reviewed by Jun Rao, Neha Narkhede; KAFKA-305	Jun Rao	More...				about 13 years ago
KAFKA-307 Refactor server code to reduce interdependencies; patched by nehanarkhede; reviewed by junrao	Neha Narkhede	More...				about 13 years ago
KAFKA-309 Bug in FileMessageSet's append API can corrupt on disk log; patched by nehanarkhede; reviewed by junrao	Neha Narkhede	More...				about 13 years ago
KAFKA-310 Incomplete message set validation checks in Log's append API can corrupt on disk log segment; patched by nehanarkhede; reviewed by junrao	Neha Narkhede	More...				about 13 years ago
KAFKA-300 Leader election; patched by nehanarkhede; reviewed by junrao	Neha Narkhede	More...				about 13 years ago
Dead code in the Log4j appender; patched by Jose Quinteiro; reviewed by Jun Rao; KAFKA-303	Jun Rao	More...				about 13 years ago
kafka-console-producer does not take in customized values of --batch-size or --timeout; patched by Jun Rao; reviewed by Edward Smith; KAFKA-279	Jun Rao	More...				about 13 years ago
reverting previous commit for KAFKA-296 because patch didn't apply cleanly	Jun Rao	More...				about 13 years ago
Update Go Client to new version of Go; patched by AaronR; KAFKA-296	Jun Rao	More...				about 13 years ago
Add acknowledgement to the produce request; patched by Prashanth Menon; reviewed by Jun Rao; KAFKA-49	Jun Rao	More...				about 13 years ago
LogManager test fails on linux; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-220	Jun Rao	More...				over 13 years ago
trivial fix to include violated payload size in MessageSizeTooLargeException; patched by Jun Rao	Jun Rao	More...				over 13 years ago
KAFKA-240 missing producer response	Joe Stein	More...				over 13 years ago
broker deletes all file segments when cleaning up an empty log segment; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-292	Jun Rao	More...				over 13 years ago
KAFKA-240 ProducerRequest wire format protocol update and related changes	Joe Stein	More...				over 13 years ago
KAFKA-239 Refactoring code to wire new ZK data structures and making partitions logical; patched by Neha Narkhede; reviewed by Jun Rao	Neha Narkhede	More...				over 13 years ago
Niek Sanders - KAFKA-284 fixed compilation issue for cpp client	Joe Stein	More...				over 13 years ago
use propertyExists to test if both broker.list and zk.connect are present; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-290	Jun Rao	More...				over 13 years ago
Increase maximum value of log.retention.size; patched by Elben Shira; reviewed by Jun Rao; KAFKA-285	Jun Rao	More...				over 13 years ago
consumer sometimes don't release partition ownership properly in ZK during rebalance; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-286	Jun Rao	More...				over 13 years ago
add jmx beans in broker to track # of failed requests; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-283	Jun Rao	More...				over 13 years ago
Add a shallow iterator to the ByteBufferMessageSet; patched by Yang Ye; reviewed by Jun Rao; KAFKA-277	Jun Rao	More...				over 13 years ago
A tool to UPDATE Zookeeper partition-offset with input from a file; patched by John Fung; reviewed by Jun Rao; KAFKA-255	Jun Rao	More...				over 13 years ago
A tool to GET Zookeeper partition-offset and output to files; patched by John Fung; reviewed by Jun Rao; KAFKA-254	Jun Rao	More...				over 13 years ago
make time-based reconnect starting at a random time; patched by Yang Ye; reviewed by Jun Rao; KAFKA-268	Jun Rao	More...				over 13 years ago
trivial fix for kafka-producer-perf-test.sh	Jun Rao	More...				over 13 years ago
test access, fixed space	Joe Stein	More...				over 13 years ago
KAFKA-274 Handle corrupted messages cleanly; patched by nehanarkhede; reviewed by junrao	Neha Narkhede	More...				over 13 years ago

←
1
2
…
520
521
522
523
524
525
526
527
528
529
530
→