This is an automated email from the ASF dual-hosted git repository. dajac pushed a commit to branch 4.0 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 593c99b0133965dceea7538db21b2cd6e238cd3f Author: David Jacot <[email protected]> AuthorDate: Tue Feb 4 14:34:57 2025 +0100 MINOR: Fix Benchmark sys tests (#18796) This patch fixes the Benchmark system tests. We misconfigured the quorum in https://github.com/apache/kafka/commit/bc7b87001bfd641f93105eaa1e0326bdaf15b55d. ``` ================================================================================ SESSION REPORT (ALL TESTS) ducktape version: 0.12.0 session_id: 2025-02-04--001 run time: 57 minutes 27.169 seconds tests run: 62 passed: 62 flaky: 0 failed: 0 ignored: 0 ================================================================================ ``` Reviewers: PoAn Yang <[email protected]>, Christo Lolov <[email protected]> --- tests/kafkatest/benchmarks/core/benchmark_test.py | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/tests/kafkatest/benchmarks/core/benchmark_test.py b/tests/kafkatest/benchmarks/core/benchmark_test.py index f66f759d46c..277f8ed264c 100644 --- a/tests/kafkatest/benchmarks/core/benchmark_test.py +++ b/tests/kafkatest/benchmarks/core/benchmark_test.py @@ -62,9 +62,9 @@ class Benchmark(Test): @parametrize(acks=1, topic=TOPIC_REP_THREE, metadata_quorum=quorum.isolated_kraft) @parametrize(acks=-1, topic=TOPIC_REP_THREE, metadata_quorum=quorum.isolated_kraft) @matrix(acks=[1], topic=[TOPIC_REP_THREE], message_size=[10, 100, 1000, 10000, 100000], - compression_type=["none", "snappy"], security_protocol=['SSL'], tls_version=['TLSv1.2', 'TLSv1.3'], metadata_quorum=quorum.isolated_kraft) + compression_type=["none", "snappy"], security_protocol=['SSL'], tls_version=['TLSv1.2', 'TLSv1.3'], metadata_quorum=[quorum.isolated_kraft]) @matrix(acks=[1], topic=[TOPIC_REP_THREE], message_size=[10, 100, 1000, 10000, 100000], - compression_type=["none", "snappy"], security_protocol=['PLAINTEXT'], metadata_quorum=quorum.isolated_kraft) + compression_type=["none", "snappy"], security_protocol=['PLAINTEXT'], metadata_quorum=[quorum.isolated_kraft]) @parametrize(acks=1, topic=TOPIC_REP_THREE, num_producers=3, metadata_quorum=quorum.isolated_kraft) def test_producer_throughput(self, acks, topic, num_producers=1, message_size=DEFAULT_RECORD_SIZE, compression_type="none", security_protocol='PLAINTEXT', tls_version=None, client_version=str(DEV_BRANCH), @@ -97,8 +97,8 @@ class Benchmark(Test): @cluster(num_nodes=7) @matrix(security_protocol=['SSL'], interbroker_security_protocol=['PLAINTEXT'], tls_version=['TLSv1.2', 'TLSv1.3'], - compression_type=["none", "snappy"], metadata_quorum=quorum.isolated_kraft) - @matrix(security_protocol=['PLAINTEXT'], compression_type=["none", "snappy"], metadata_quorum=quorum.isolated_kraft) + compression_type=["none", "snappy"], metadata_quorum=[quorum.isolated_kraft]) + @matrix(security_protocol=['PLAINTEXT'], compression_type=["none", "snappy"], metadata_quorum=[quorum.isolated_kraft]) def test_long_term_producer_throughput(self, compression_type="none", security_protocol='PLAINTEXT', tls_version=None, interbroker_security_protocol=None, client_version=str(DEV_BRANCH), @@ -155,9 +155,9 @@ class Benchmark(Test): @cluster(num_nodes=8) @matrix(security_protocol=['SSL'], interbroker_security_protocol=['PLAINTEXT'], tls_version=['TLSv1.2', 'TLSv1.3'], - compression_type=["none", "snappy"], metadata_quorum=quorum.isolated_kraft) - @matrix(security_protocol=['PLAINTEXT'], compression_type=["none", "snappy"], metadata_quorum=quorum.isolated_kraft) - @matrix(security_protocol=['SASL_PLAINTEXT', 'SASL_SSL'], compression_type=["none", "snappy"], metadata_quorum=quorum.isolated_kraft) + compression_type=["none", "snappy"], metadata_quorum=[quorum.isolated_kraft]) + @matrix(security_protocol=['PLAINTEXT'], compression_type=["none", "snappy"], metadata_quorum=[quorum.isolated_kraft]) + @matrix(security_protocol=['SASL_PLAINTEXT', 'SASL_SSL'], compression_type=["none", "snappy"], metadata_quorum=[quorum.isolated_kraft]) def test_end_to_end_latency(self, compression_type="none", security_protocol="PLAINTEXT", tls_version=None, interbroker_security_protocol=None, client_version=str(DEV_BRANCH), broker_version=str(DEV_BRANCH), metadata_quorum=quorum.isolated_kraft): @@ -187,8 +187,8 @@ class Benchmark(Test): @cluster(num_nodes=8) @matrix(security_protocol=['SSL'], interbroker_security_protocol=['PLAINTEXT'], tls_version=['TLSv1.2', 'TLSv1.3'], - compression_type=["none", "snappy"], metadata_quorum=quorum.isolated_kraft) - @matrix(security_protocol=['PLAINTEXT'], compression_type=["none", "snappy"], metadata_quorum=quorum.isolated_kraft) + compression_type=["none", "snappy"], metadata_quorum=[quorum.isolated_kraft]) + @matrix(security_protocol=['PLAINTEXT'], compression_type=["none", "snappy"], metadata_quorum=[quorum.isolated_kraft]) def test_producer_and_consumer(self, compression_type="none", security_protocol="PLAINTEXT", tls_version=None, interbroker_security_protocol=None, client_version=str(DEV_BRANCH), broker_version=str(DEV_BRANCH), metadata_quorum=quorum.isolated_kraft): @@ -235,8 +235,8 @@ class Benchmark(Test): @cluster(num_nodes=8) @matrix(security_protocol=['SSL'], interbroker_security_protocol=['PLAINTEXT'], tls_version=['TLSv1.2', 'TLSv1.3'], - compression_type=["none", "snappy"], metadata_quorum=quorum.isolated_kraft) - @matrix(security_protocol=['PLAINTEXT'], compression_type=["none", "snappy"], metadata_quorum=quorum.isolated_kraft) + compression_type=["none", "snappy"], metadata_quorum=[quorum.isolated_kraft]) + @matrix(security_protocol=['PLAINTEXT'], compression_type=["none", "snappy"], metadata_quorum=[quorum.isolated_kraft]) def test_consumer_throughput(self, compression_type="none", security_protocol="PLAINTEXT", tls_version=None, interbroker_security_protocol=None, num_consumers=1, client_version=str(DEV_BRANCH), broker_version=str(DEV_BRANCH), metadata_quorum=quorum.isolated_kraft):
