Apache Kafka

Settings | Report Duplicate

17

I Use This!

Very High Activity

Commits : Listings

Analyzed about 12 hours ago. based on code collected about 12 hours ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Jun 13, 2024 — Jun 13, 2025 Showing page 530 of 531 Search / Filter on:
JMX bean that reports #message/sec in consumer; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-136	Jun Rao	More...				over 13 years ago
Expose total metrics through MBeansp; patched by Pierre-Yves Ritschard; reviewed by Jun Rao; KAFKA-140	Jun Rao	More...				over 13 years ago
trival fix to make hash code positive; patched by Joel Koshy; reviewed by Jun Rao	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	Jun Rao	More...				over 13 years ago
Consumer needs a pluggable decoder; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-3	Jun Rao	More...				over 13 years ago
ruby kafka gem is not functional; patched by Pierre-Yves Ritschard; KAFKA-135	Jun Rao	More...				over 13 years ago
Log flush should complete upon broker shutdown; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-126	Jun Rao	More...				over 13 years ago
Fix ASF license headers for C# client; patched by Eric Hauser; #KAFKA-137	Jun Rao	More...				over 13 years ago
enhancements to .Net; patched by Eric Hauser; KAFKA-85	Jun Rao	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.	Edward Jay Kreps	More...				over 13 years ago
KAFKA-70 Patch from Prashanth Menon to add space-based retention setting.	Edward Jay Kreps	More...				over 13 years ago
Tool to watch consumer offsets and lag; patched by Joel Joshy; reviewed by Jun Rao; KAFKA-127	Jun Rao	More...				almost 14 years ago
Hadoop Consumer goes into an infinite loop; patched by Sam William; reviewed by Richard Park; KAFKA-131	Jun Rao	More...				almost 14 years ago
fix string formatting; write data to stdout in ConsumerShell	Jun Rao	More...				almost 14 years ago
DumpLogSegments outputs wrong offsets; kafka-128 patched by junrao; reviewed by Joel	Jun Rao	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.	Edward Jay Kreps	More...				almost 14 years ago
Enable logging for tests, at a reasonable verbosity patch by cburroughs; reviewed by junrao for KAFKA-113	Chris Burroughs	More...				almost 14 years ago
more info in DumpLogSegments; KAFKA-122 ; patched by Jun; reviewed by Neha	Jun Rao	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	Neha Narkhede	More...				almost 14 years ago
Code clean up in FetcherRunnable and ZookeeperConsumerConnector; KAFKA-120; patched by junrao; reviewed by nehanarkhede	Neha Narkhede	More...				almost 14 years ago
The FetcherRunnable busy waits on empty fetch requests; KAFKA-117; patched by nehanarkhede; reviewed by junrao	Neha Narkhede	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	Neha Narkhede	More...				almost 14 years ago
AsyncProducer shutdown logic causes data loss; KAFKA-116; patched by nehanarkhede; reviewed by junrao	Neha Narkhede	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	Chris Burroughs	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	Neha Narkhede	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	Neha Narkhede	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.	Edward Jay Kreps	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	Neha Narkhede	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	Neha Narkhede	More...				almost 14 years ago
Some new unit tests for ByteBufferMessageSet iterator KAFKA-108; patched by Jun; reviewed by Neha	Neha Narkhede	More...				almost 14 years ago

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