17
I Use This!
Very High Activity

Commits : Listings

Analyzed about 12 hours ago. based on code collected about 12 hours ago.
Jun 13, 2024 — Jun 13, 2025
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
JMX bean that reports #message/sec in consumer; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-136 More... over 13 years ago
Expose total metrics through MBeansp; patched by Pierre-Yves Ritschard; reviewed by Jun Rao; KAFKA-140 More... over 13 years ago
trival fix to make hash code positive; patched by Joel Koshy; reviewed by Jun Rao More... over 13 years ago
Bug in the queue timeout logic of the async producer; patched by Neha Narkhede; reviewed by Jun Rao; KAFKA-138 More... over 13 years ago
Consumer needs a pluggable decoder; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-3 More... over 13 years ago
ruby kafka gem is not functional; patched by Pierre-Yves Ritschard; KAFKA-135 More... over 13 years ago
Log flush should complete upon broker shutdown; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-126 More... over 13 years ago
Fix ASF license headers for C# client; patched by Eric Hauser; #KAFKA-137 More... over 13 years ago
enhancements to .Net; patched by Eric Hauser; KAFKA-85 More... over 13 years ago
KAFKA-132 Patch from Scott Andreas to avoid flush when there is nothing to flush. Looks like due to atime attribute in the filesystem this can lead to flushing file metadata. More... over 13 years ago
KAFKA-70 Patch from Prashanth Menon to add space-based retention setting. More... over 13 years ago
Tool to watch consumer offsets and lag; patched by Joel Joshy; reviewed by Jun Rao; KAFKA-127 More... almost 14 years ago
Hadoop Consumer goes into an infinite loop; patched by Sam William; reviewed by Richard Park; KAFKA-131 More... almost 14 years ago
fix string formatting; write data to stdout in ConsumerShell More... almost 14 years ago
DumpLogSegments outputs wrong offsets; kafka-128 patched by junrao; reviewed by Joel More... almost 14 years ago
KAFKA-124 Console consumer does not stop consuming if the program reading from standard out dies. Check for errors on the output stream and exit if no one is listening. More... almost 14 years ago
Enable logging for tests, at a reasonable verbosity patch by cburroughs; reviewed by junrao for KAFKA-113 More... almost 14 years ago
more info in DumpLogSegments; KAFKA-122 ; patched by Jun; reviewed by Neha More... almost 14 years ago
A new file part of KAFKA-116 was accidentally not checked in. This commit fixes it; patched by nehanarkhede; reviewed by chrisburroughs More... almost 14 years ago
Code clean up in FetcherRunnable and ZookeeperConsumerConnector; KAFKA-120; patched by junrao; reviewed by nehanarkhede More... almost 14 years ago
The FetcherRunnable busy waits on empty fetch requests; KAFKA-117; patched by nehanarkhede; reviewed by junrao More... almost 14 years ago
Producer performance tool should use the new blocking async producer instead of the sleep timeout hack; KAFKA-118; patched by nehanarkhede; reviewed by junrao More... almost 14 years ago
AsyncProducer shutdown logic causes data loss; KAFKA-116; patched by nehanarkhede; reviewed by junrao More... almost 14 years ago
Explicitly list ZooKeeper as a dependency instead of including jar in-tree patch by cburroughs; reviewed by nehanarkhede and hsaputra for KAFKA-90 More... almost 14 years ago
Improve the command line tools in the bin directory to use the compression feature correctly; KAFKA-112; patched by nehanarkhede; reviewed by junrao More... almost 14 years ago
Kafka server access log does not log request details coming from a MultiProduceRequest; KAFKA-115; patched by nehanarkhede; reviewed by junrao More... almost 14 years ago
KAFKA-99 Enforce a max request size in socket server to avoid running out of memory with very large requests. More... almost 14 years ago
ByteBufferMessageSet iterator bug returning incorrect offsets after reading a compressed empty message set KAFKA-111; patched by Jun; reviewed by Neha More... almost 14 years ago
Bug in the collate logic of the DefaultEventHandler dispatches empty list of messages using the producer KAFKA-110; patched by Neha; reviewed by Jun More... almost 14 years ago
Some new unit tests for ByteBufferMessageSet iterator KAFKA-108; patched by Jun; reviewed by Neha More... almost 14 years ago