This is an automated email from the ASF dual-hosted git repository.
rsivaram pushed a commit to branch 2.5
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.5 by this push:
new 933370c KAFKA-9797; Fix
TestSecurityRollingUpgrade.test_enable_separate_interbroker_listener (#8403)
933370c is described below
commit 933370c39ea4c159fa546513913249e95d37b882
Author: Rajini Sivaram <[email protected]>
AuthorDate: Wed Apr 15 13:04:11 2020 +0100
KAFKA-9797; Fix
TestSecurityRollingUpgrade.test_enable_separate_interbroker_listener (#8403)
Reviewers: Manikumar Reddy <[email protected]>, Ismael Juma
<[email protected]>
---
tests/kafkatest/tests/core/security_rolling_upgrade_test.py | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/tests/kafkatest/tests/core/security_rolling_upgrade_test.py
b/tests/kafkatest/tests/core/security_rolling_upgrade_test.py
index 3c63ec7..853bed2 100644
--- a/tests/kafkatest/tests/core/security_rolling_upgrade_test.py
+++ b/tests/kafkatest/tests/core/security_rolling_upgrade_test.py
@@ -96,10 +96,15 @@ class
TestSecurityRollingUpgrade(ProduceConsumeValidateTest):
self.set_authorizer_and_bounce(security_protocol, security_protocol,
KafkaService.SIMPLE_AUTHORIZER)
def add_separate_broker_listener(self, broker_security_protocol,
broker_sasl_mechanism):
+ # Enable the new internal listener on all brokers first
+ self.kafka.open_port(self.kafka.INTERBROKER_LISTENER_NAME)
+
self.kafka.port_mappings[self.kafka.INTERBROKER_LISTENER_NAME].security_protocol
= broker_security_protocol
+ self.kafka.client_sasl_mechanism = broker_sasl_mechanism
+ self.bounce()
+
+ # Update inter-broker listener after all brokers have been updated to
enable the new listener
self.kafka.setup_interbroker_listener(broker_security_protocol, True)
self.kafka.interbroker_sasl_mechanism = broker_sasl_mechanism
- # kafka opens interbroker port automatically in start() but not in
bounce()
- self.kafka.open_port(self.kafka.INTERBROKER_LISTENER_NAME)
self.bounce()
def remove_separate_broker_listener(self, client_security_protocol,
client_sasl_mechanism):
