root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

left out a file from last commit

This commit is contained in:
Geoff Anderson 2015-06-03 18:12:11 -07:00
parent 1228eefc4e
commit 6842ed1ffa
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
clients/src/main/java/org/apache/kafka/clients/tools/VerifiableProducer.java
View File

@ -249,7 +249,7 @@ public class VerifiableProducer {
} }
}); });
MessageThroughputThrottler throttler = new MessageThroughputThrottler(producer.throughput, startMs); ThroughputThrottler throttler = new ThroughputThrottler(producer.throughput, startMs);
for (int i = 0; i < producer.maxMessages || infinite; i++) { for (int i = 0; i < producer.maxMessages || infinite; i++) {
long sendStartMs = System.currentTimeMillis(); long sendStartMs = System.currentTimeMillis();
producer.send(null, String.format("%d", i)); producer.send(null, String.format("%d", i));