@@ -172,24 +172,16 @@ pub fn controller_kafka_container_command(
172172 wait_for_termination $!
173173 {create_vector_shutdown_file_command}
174174 " ,
175- remove_vector_shutdown_file_command = remove_vector_shutdown_file_command( STACKABLE_LOG_DIR ) ,
176- config_dir = STACKABLE_CONFIG_DIR ,
177- properties_file = CONTROLLER_PROPERTIES_FILE ,
178- bootstrap_servers = to_bootstrap_servers( & controller_descriptors, client_port) ,
179- listeners = to_listeners( client_port) ,
180- listener_security_protocol_map = to_listener_security_protocol_map( kafka_listeners) ,
181- initial_controller_command = initial_controllers_command( & controller_descriptors, product_version, client_port) ,
182- controller_quorum_voters = to_quorum_voters( & controller_descriptors, client_port) ,
183- create_vector_shutdown_file_command = create_vector_shutdown_file_command( STACKABLE_LOG_DIR )
184-
185-
186- controller. quorum. bootstrap. servers=test-kafka-controller-default -0 . test-kafka-controller-default . kuttl-test-cute-ghoul. svc. cluster. local: 9093 , test-kafka-controller-default -1 . test-kafka-controller-default . kuttl-test-cute-ghoul. svc. cluster. local: 9093 , test-kafka-controller-default -2 . test-kafka-controller-default . kuttl-test-cute-ghoul. svc. cluster. local: 9093
187- listeners=CONTROLLER : //test-kafka-controller-default-1.test-kafka-controller-default.kuttl-test-cute-ghoul.svc.cluster.local:9093
188- listener. security. protocol. map=CONTROLLER : SSL
189- controller. quorum. voters=2110489703 @test-kafka-controller-default -0 . test-kafka-controller-default . kuttl-test-cute-ghoul. svc. cluster. local: 9093 , 2110489704 @test-kafka-controller-default -1 . test-kafka-controller-default . kuttl-test-cute-ghoul. svc. cluster. local: 9093 , 2110489705 @test-kafka-controller-default -2 . test-kafka-controller-default . kuttl-test-cute-ghoul. svc. cluster. local: 9093
190-
191-
192- }
175+ remove_vector_shutdown_file_command = remove_vector_shutdown_file_command( STACKABLE_LOG_DIR ) ,
176+ config_dir = STACKABLE_CONFIG_DIR ,
177+ properties_file = CONTROLLER_PROPERTIES_FILE ,
178+ bootstrap_servers = to_bootstrap_servers( & controller_descriptors, client_port) ,
179+ listeners = to_listeners( client_port) ,
180+ listener_security_protocol_map = to_listener_security_protocol_map( kafka_listeners) ,
181+ initial_controller_command = initial_controllers_command( & controller_descriptors, product_version, client_port) ,
182+ controller_quorum_voters = to_quorum_voters( & controller_descriptors, client_port) ,
183+ create_vector_shutdown_file_command = create_vector_shutdown_file_command( STACKABLE_LOG_DIR )
184+ }
193185}
194186
195187fn to_listeners ( port : u16 ) -> String {
0 commit comments