[kafka] branch trunk updated: MINOR: fix number of nodes used in test_compatible_brokers_eos_v2_enabled (#12211)

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 46630a0610 MINOR: fix number of nodes used in test_compatible_brokers_eos_v2_enabled (#12211)
46630a0610 is described below

commit 46630a0610746e2b59e7ee130fbc277c50c9d19e
Author: Lucas Bradstreet <lu...@gmail.com>
AuthorDate: Wed May 25 11:03:06 2022 -0700

    MINOR: fix number of nodes used in test_compatible_brokers_eos_v2_enabled (#12211)
    
    Reviewers: David Jacot <dj...@confluent.io>
---
 tests/kafkatest/tests/streams/streams_broker_compatibility_test.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py b/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
index 83b0735af7..d2ab4d184d 100644
--- a/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
+++ b/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
@@ -115,6 +115,7 @@ class StreamsBrokerCompatibility(Test):
         self.consumer.stop()
         self.kafka.stop()
 
+    @cluster(num_nodes=4)
     @parametrize(broker_version=str(LATEST_2_8))
     @parametrize(broker_version=str(LATEST_2_7))
     @parametrize(broker_version=str(LATEST_2_6))