瀏覽代碼

Add partition per message on producer performance tool (bug fix)

AJ Yoo 7 年之前
父節點
當前提交
d4410b55bc
共有 1 個文件被更改,包括 3 次插入2 次删除
  1. 3 2
      tools/kafka-producer-performance/main.go

+ 3 - 2
tools/kafka-producer-performance/main.go

@@ -215,8 +215,9 @@ func main() {
 			printErrorAndExit(69, "Failed to generate message payload: %s", err)
 			printErrorAndExit(69, "Failed to generate message payload: %s", err)
 		}
 		}
 		messages[i] = &sarama.ProducerMessage{
 		messages[i] = &sarama.ProducerMessage{
-			Topic: *topic,
-			Value: sarama.ByteEncoder(payload),
+			Topic:     *topic,
+			Partition: int32(*partition),
+			Value:     sarama.ByteEncoder(payload),
 		}
 		}
 	}
 	}