[kafka] branch 2.8 updated: MINOR: fix some ducktape test issues (#10181)

[cm...@apache.org]

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

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


The following commit(s) were added to refs/heads/2.8 by this push:
     new f06e16b  MINOR: fix some ducktape test issues (#10181)
f06e16b is described below

commit f06e16b026be93547179834fc8def8d2424e2942
Author: Ron Dagostino <rd...@confluent.io>
AuthorDate: Mon Feb 22 18:09:25 2021 -0500

    MINOR: fix some ducktape test issues (#10181)
    
    Reviewers: Colin P. McCabe <cm...@apache.org>
---
 tests/kafkatest/tests/core/security_test.py                         | 4 ++--
 .../kafkatest/tests/streams/streams_broker_down_resilience_test.py  | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/tests/kafkatest/tests/core/security_test.py b/tests/kafkatest/tests/core/security_test.py
index 5d1d886..8dcc264 100644
--- a/tests/kafkatest/tests/core/security_test.py
+++ b/tests/kafkatest/tests/core/security_test.py
@@ -58,8 +58,8 @@ class SecurityTest(EndToEndTest):
         return True
 
     @cluster(num_nodes=7)
-    @matrix(security_protocol='PLAINTEXT', interbroker_security_protocol='SSL', metadata_quorum=quorum.all_non_upgrade)
-    @matrix(security_protocol='SSL', interbroker_security_protocol='PLAINTEXT', metadata_quorum=quorum.all_non_upgrade)
+    @matrix(security_protocol=['PLAINTEXT'], interbroker_security_protocol=['SSL'], metadata_quorum=quorum.all_non_upgrade)
+    @matrix(security_protocol=['SSL'], interbroker_security_protocol=['PLAINTEXT'], metadata_quorum=quorum.all_non_upgrade)
     def test_client_ssl_endpoint_validation_failure(self, security_protocol, interbroker_security_protocol, metadata_quorum=quorum.zk):
         """
         Test that invalid hostname in certificate results in connection failures.
diff --git a/tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py b/tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py
index 5026d7a..6957d69 100644
--- a/tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py
+++ b/tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py
@@ -41,7 +41,7 @@ class StreamsBrokerDownResilience(BaseStreamsTest):
     def setUp(self):
         self.zk.start()
 
-    @cluster(num_nodes=5)
+    @cluster(num_nodes=7)
     def test_streams_resilient_to_broker_down(self):
         self.kafka.start()
 
@@ -144,7 +144,7 @@ class StreamsBrokerDownResilience(BaseStreamsTest):
 
         self.kafka.stop()
 
-    @cluster(num_nodes=7)
+    @cluster(num_nodes=9)
     def test_streams_should_scale_in_while_brokers_down(self):
         self.kafka.start()
 
@@ -222,7 +222,7 @@ class StreamsBrokerDownResilience(BaseStreamsTest):
 
         self.kafka.stop()
 
-    @cluster(num_nodes=7)
+    @cluster(num_nodes=9)
     def test_streams_should_failover_while_brokers_down(self):
         self.kafka.start()