diff --git a/tests/kafkatest/services/kafka/kafka.py b/tests/kafkatest/services/kafka/kafka.py index a28106d7b3068..af1133716f748 100644 --- a/tests/kafkatest/services/kafka/kafka.py +++ b/tests/kafkatest/services/kafka/kafka.py @@ -602,12 +602,6 @@ def start_minikdc_if_necessary(self, add_principals=""): nodes_for_kdc += other_service.nodes self.minikdc = MiniKdc(self.context, nodes_for_kdc, extra_principals = add_principals) self.minikdc.start() - else: - self.minikdc = None - if self.quorum_info.using_kraft: - self.controller_quorum.minikdc = None - if self.isolated_kafka: - self.isolated_kafka.minikdc = None def alive(self, node): return len(self.pids(node)) > 0