File tree Expand file tree Collapse file tree 2 files changed +1
-6
lines changed Expand file tree Collapse file tree 2 files changed +1
-6
lines changed Original file line number Diff line number Diff line change @@ -175,20 +175,16 @@ pub fn controller_kafka_container_command(
175
175
}
176
176
177
177
fn 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
181
179
format ! (
182
180
"{listener_name}://$POD_NAME.$ROLEGROUP_REF.$NAMESPACE.svc.$CLUSTER_DOMAIN:{port}" ,
183
181
listener_name = KafkaListenerName :: Controller
184
182
)
185
183
}
186
184
187
185
fn to_listener_security_protocol_map ( kafka_listeners : & KafkaListenerConfig ) -> String {
188
- // TODO: make configurable - CONTROLLER_AUTH
189
186
kafka_listeners
190
187
. listener_security_protocol_map_for_listener ( & KafkaListenerName :: Controller )
191
- // todo better error
192
188
. unwrap_or ( "" . to_string ( ) )
193
189
}
194
190
Original file line number Diff line number Diff line change @@ -42,7 +42,6 @@ pub const CONTROLLER_PROPERTIES_FILE: &str = "controller.properties";
42
42
#[ strum( serialize_all = "kebab-case" ) ]
43
43
pub enum ControllerContainer {
44
44
Vector ,
45
- // TODO: Kafka, Kraft, Controller?
46
45
Kafka ,
47
46
}
48
47
You can’t perform that action at this time.
0 commit comments