File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -175,20 +175,16 @@ pub fn controller_kafka_container_command(
175175}
176176
177177fn to_listeners ( port : u16 ) -> String {
178- // TODO:
179- // - document that variables are set in stateful set
180- // - customize listener (CONTROLLER / CONTROLLER_AUTH?)
178+ // The environment variables are set in the statefulset of the controller
181179 format ! (
182180 "{listener_name}://$POD_NAME.$ROLEGROUP_REF.$NAMESPACE.svc.$CLUSTER_DOMAIN:{port}" ,
183181 listener_name = KafkaListenerName :: Controller
184182 )
185183}
186184
187185fn to_listener_security_protocol_map ( kafka_listeners : & KafkaListenerConfig ) -> String {
188- // TODO: make configurable - CONTROLLER_AUTH
189186 kafka_listeners
190187 . listener_security_protocol_map_for_listener ( & KafkaListenerName :: Controller )
191- // todo better error
192188 . unwrap_or ( "" . to_string ( ) )
193189}
194190
Original file line number Diff line number Diff line change @@ -42,7 +42,6 @@ pub const CONTROLLER_PROPERTIES_FILE: &str = "controller.properties";
4242#[ strum( serialize_all = "kebab-case" ) ]
4343pub enum ControllerContainer {
4444 Vector ,
45- // TODO: Kafka, Kraft, Controller?
4645 Kafka ,
4746}
4847
You can’t perform that action at this time.
0 commit comments