From 58b3b1b557e9ba19cffde91bd117a89b947f1fc1 Mon Sep 17 00:00:00 2001 From: Ron Dagostino Date: Mon, 1 Mar 2021 10:46:24 -0500 Subject: [PATCH 1/2] MINOR: fix failing system test delegation_token_test --- tests/kafkatest/services/security/security_config.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tests/kafkatest/services/security/security_config.py b/tests/kafkatest/services/security/security_config.py index 9ab7e6fa9c02f..d7c9e7464a377 100644 --- a/tests/kafkatest/services/security/security_config.py +++ b/tests/kafkatest/services/security/security_config.py @@ -374,7 +374,8 @@ def interbroker_sasl_mechanism(self): def enabled_sasl_mechanisms(self): sasl_mechanisms = [] if self.is_sasl(self.security_protocol): - sasl_mechanisms += [self.client_sasl_mechanism] + # .csv is supported so be sure to account for that possibility + sasl_mechanisms += self.client_sasl_mechanism.strip().split(',') if self.is_sasl(self.interbroker_security_protocol): sasl_mechanisms += [self.interbroker_sasl_mechanism] if self.serves_raft_sasl: From ba16000e632e97d00f3cd24bcdbd532c7637ddb6 Mon Sep 17 00:00:00 2001 From: Ron Dagostino Date: Tue, 2 Mar 2021 13:47:04 -0500 Subject: [PATCH 2/2] Deal with possibility of internal spaces in client_sasl_mechnism .csv --- tests/kafkatest/services/security/security_config.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/kafkatest/services/security/security_config.py b/tests/kafkatest/services/security/security_config.py index d7c9e7464a377..5be0737f715d8 100644 --- a/tests/kafkatest/services/security/security_config.py +++ b/tests/kafkatest/services/security/security_config.py @@ -375,7 +375,7 @@ def enabled_sasl_mechanisms(self): sasl_mechanisms = [] if self.is_sasl(self.security_protocol): # .csv is supported so be sure to account for that possibility - sasl_mechanisms += self.client_sasl_mechanism.strip().split(',') + sasl_mechanisms += [mechanism.strip() for mechanism in self.client_sasl_mechanism.split(',')] if self.is_sasl(self.interbroker_security_protocol): sasl_mechanisms += [self.interbroker_sasl_mechanism] if self.serves_raft_sasl: