From 7d51633a396383db7ce00cba31864cb03839c99f Mon Sep 17 00:00:00 2001
From: jet <qq471723562@126.com>
Date: Sun, 20 Jun 2021 10:07:54 +0800
Subject: [PATCH] fix throughput error

---
 tools/kafka-producer-performance/main.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/tools/kafka-producer-performance/main.go b/tools/kafka-producer-performance/main.go
index 2d40431d8..05b513179 100644
--- a/tools/kafka-producer-performance/main.go
+++ b/tools/kafka-producer-performance/main.go
@@ -347,11 +347,11 @@ func runAsyncProducer(topic string, partition, messageLoad, messageSize int,
 
 	if throughput > 0 {
 		ticker := time.NewTicker(time.Second)
-		for _, message := range messages {
-			for i := 0; i < throughput; i++ {
-				producer.Input() <- message
+		for idx, message := range messages {
+			producer.Input() <- message
+			if (idx+1)%throughput == 0 {
+				<-ticker.C
 			}
-			<-ticker.C
 		}
 		ticker.Stop()
 	} else {