Apache Kafka

Settings | Report Duplicate

17

I Use This!

Very High Activity

Commits : Listings

Analyzed about 9 hours ago. based on code collected about 10 hours ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Jun 09, 2024 — Jun 09, 2025 Showing page 525 of 530 Search / Filter on:
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
shutdown watch executor thread properly; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-265	Jun Rao	More...				over 13 years ago
trivial fix to add trace logging in FetcherRunnable	Jun Rao	More...				over 13 years ago
fix condition to use await instead of wait; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-265	Jun Rao	More...				over 13 years ago
add JMX on broker to track bytes/messages per topic; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-272	Jun Rao	More...				over 13 years ago
disable dup topic in consumer request; patched by Prashanth Menon; reviewed by Jun Rao; KAFKA-240	Jun Rao	More...				over 13 years ago
time-based reconnect in producer; patched by Yang Ye; reviewed by Jun Rao; KAFKA-268	Jun Rao	More...				over 13 years ago
Add a queue of zookeeper notifications in the zookeeper consumer to reduce the number of rebalancing attempts; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-265	Jun Rao	More...				over 13 years ago
new consumer request format; patched by Prashanth Menon; reviewed by Jun Rao and Jay Kreps; KAFKA-240	Jun Rao	More...				over 13 years ago
trivial change to reduce default fetcher queue size	Jun Rao	More...				over 13 years ago
KAFKA-262 Bug in the consumer rebalancing logic causes one consumer to release partitions that it does not own; patched by Neha Narkhede; reviewed by Jun Rao	Neha Narkhede	More...				over 13 years ago
refactor the async producer; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-253	Jun Rao	More...				over 13 years ago
KAFKA-263 Enhance single host broker failure test to have 2 topics with uneven distribution on the source brokers; patched by John Fung; reviewed by Neha Narkhede	Neha Narkhede	More...				over 13 years ago
KAFKA-257 Hadoop producer should use software load balancer; patched by Sam Shah; reviewed by nehanarkhede	Neha Narkhede	More...				over 13 years ago

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