|
10 | 10 | except (ImportError, AttributeError): |
11 | 11 | from pydantic import Field, SecretStr, validator # type: ignore[no-redef, assignment] |
12 | 12 |
|
| 13 | +from onetl._util.alias import avoid_alias |
13 | 14 | from onetl._util.file import is_file_readable |
14 | 15 | from onetl._util.spark import stringify |
15 | 16 | from onetl.impl import GenericOptions, LocalPath |
@@ -148,17 +149,25 @@ class KafkaSSLProtocol(KafkaProtocol, GenericOptions): |
148 | 149 | ) |
149 | 150 | """ |
150 | 151 |
|
151 | | - keystore_type: Optional[str] = Field(default=None, alias="ssl.keystore.type") |
152 | | - keystore_location: Optional[LocalPath] = Field(default=None, alias="ssl.keystore.location") |
153 | | - keystore_password: Optional[SecretStr] = Field(default=None, alias="ssl.keystore.password") |
154 | | - keystore_certificate_chain: Optional[str] = Field(default=None, alias="ssl.keystore.certificate.chain", repr=False) |
155 | | - keystore_key: Optional[SecretStr] = Field(default=None, alias="ssl.keystore.key") |
| 152 | + keystore_type: Optional[str] = Field(default=None, alias=avoid_alias("ssl.keystore.type")) |
| 153 | + keystore_location: Optional[LocalPath] = Field(default=None, alias=avoid_alias("ssl.keystore.location")) |
| 154 | + keystore_password: Optional[SecretStr] = Field(default=None, alias=avoid_alias("ssl.keystore.password")) |
| 155 | + keystore_certificate_chain: Optional[str] = Field( |
| 156 | + default=None, |
| 157 | + alias=avoid_alias("ssl.keystore.certificate.chain"), |
| 158 | + repr=False, |
| 159 | + ) |
| 160 | + keystore_key: Optional[SecretStr] = Field(default=None, alias=avoid_alias("ssl.keystore.key")) |
156 | 161 | # https://knowledge.informatica.com/s/article/145442?language=en_US |
157 | | - key_password: Optional[SecretStr] = Field(default=None, alias="ssl.key.password") |
158 | | - truststore_type: str = Field(alias="ssl.truststore.type") |
159 | | - truststore_location: Optional[LocalPath] = Field(default=None, alias="ssl.truststore.location") |
160 | | - truststore_password: Optional[SecretStr] = Field(default=None, alias="ssl.truststore.password") |
161 | | - truststore_certificates: Optional[str] = Field(default=None, alias="ssl.truststore.certificates", repr=False) |
| 162 | + key_password: Optional[SecretStr] = Field(default=None, alias=avoid_alias("ssl.key.password")) |
| 163 | + truststore_type: str = Field(alias=avoid_alias("ssl.truststore.type")) |
| 164 | + truststore_location: Optional[LocalPath] = Field(default=None, alias=avoid_alias("ssl.truststore.location")) |
| 165 | + truststore_password: Optional[SecretStr] = Field(default=None, alias=avoid_alias("ssl.truststore.password")) |
| 166 | + truststore_certificates: Optional[str] = Field( |
| 167 | + default=None, |
| 168 | + alias=avoid_alias("ssl.truststore.certificates"), |
| 169 | + repr=False, |
| 170 | + ) |
162 | 171 |
|
163 | 172 | class Config: |
164 | 173 | known_options = frozenset(("ssl.*",)) |
|
0 commit comments