Skip to content

Commit 47abc7e

Browse files
committed
Revert "remove controller listener from broker config"
This reverts commit 01b1a05.
1 parent 5c7eda0 commit 47abc7e

1 file changed

Lines changed: 25 additions & 0 deletions

File tree

rust/operator-binary/src/crd/security.rs

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -653,6 +653,31 @@ impl KafkaTlsSecurity {
653653
KafkaListenerName::Internal.listener_ssl_truststore_type(),
654654
"PKCS12".to_string(),
655655
);
656+
// CONTROLLERS
657+
config.insert(
658+
KafkaListenerName::Controller.listener_ssl_keystore_location(),
659+
format!("{}/keystore.p12", Self::STACKABLE_TLS_KAFKA_INTERNAL_DIR),
660+
);
661+
config.insert(
662+
KafkaListenerName::Controller.listener_ssl_keystore_password(),
663+
Self::SSL_STORE_PASSWORD.to_string(),
664+
);
665+
config.insert(
666+
KafkaListenerName::Controller.listener_ssl_keystore_type(),
667+
"PKCS12".to_string(),
668+
);
669+
config.insert(
670+
KafkaListenerName::Controller.listener_ssl_truststore_location(),
671+
format!("{}/truststore.p12", Self::STACKABLE_TLS_KAFKA_INTERNAL_DIR),
672+
);
673+
config.insert(
674+
KafkaListenerName::Controller.listener_ssl_truststore_password(),
675+
Self::SSL_STORE_PASSWORD.to_string(),
676+
);
677+
config.insert(
678+
KafkaListenerName::Controller.listener_ssl_truststore_type(),
679+
"PKCS12".to_string(),
680+
);
656681
// client auth required
657682
config.insert(
658683
KafkaListenerName::Internal.listener_ssl_client_auth(),

0 commit comments

Comments
 (0)