Skip to content

Commit c565ba1

Browse files
KAFKA-19598: Command-line arguments for producer perf test (#20361)
This implements KIP-1147 for kafka-producer-perf-test.sh. Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
1 parent de92b20 commit c565ba1

File tree

4 files changed

+304
-104
lines changed

4 files changed

+304
-104
lines changed

docs/ops.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4318,7 +4318,7 @@ <h4 class="anchor-heading"><a id="tiered_storage_config_ex" class="anchor-link">
43184318

43194319
<p>Try to send messages to the `tieredTopic` topic to roll the log segment:</p>
43204320

4321-
<pre><code class="language-bash">$ bin/kafka-producer-perf-test.sh --topic tieredTopic --num-records 1200 --record-size 1024 --throughput -1 --producer-props bootstrap.servers=localhost:9092</code></pre>
4321+
<pre><code class="language-bash">$ bin/kafka-producer-perf-test.sh --bootstrap-server localhost:9092 --topic tieredTopic --num-records 1200 --record-size 1024 --throughput -1</code></pre>
43224322

43234323
<p>Then, after the active segment is rolled, the old segment should be moved to the remote storage and get deleted.
43244324
This can be verified by checking the remote log directory configured above. For example:

tests/kafkatest/services/performance/producer_performance.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ def start_cmd(self, node):
9191

9292
cmd += " export KAFKA_LOG4J_OPTS=\"%s%s\"; " % (get_log4j_config_param(node), get_log4j_config_for_tools(node))
9393
cmd += "KAFKA_OPTS=%(kafka_opts)s KAFKA_HEAP_OPTS=\"-XX:+HeapDumpOnOutOfMemoryError\" %(kafka_run_class)s org.apache.kafka.tools.ProducerPerformance " \
94-
"--topic %(topic)s --num-records %(num_records)d --record-size %(record_size)d --throughput %(throughput)d --producer-props bootstrap.servers=%(bootstrap_servers)s client.id=%(client_id)s %(metrics_props)s" % args
94+
"--topic %(topic)s --num-records %(num_records)d --record-size %(record_size)d --throughput %(throughput)d --command-property bootstrap.servers=%(bootstrap_servers)s client.id=%(client_id)s %(metrics_props)s" % args
9595

9696
self.security_config.setup_node(node)
9797
if self.security_config.security_protocol != SecurityConfig.PLAINTEXT:

0 commit comments

Comments
 (0)