Allow SSL security_protocol configuration property in apache_kafka component (#128651)
parent
0581d614f6
commit
201aab9f73
|
@ -38,7 +38,7 @@ CONFIG_SCHEMA = vol.Schema(
|
|||
vol.Required(CONF_TOPIC): cv.string,
|
||||
vol.Optional(CONF_FILTER, default={}): FILTER_SCHEMA,
|
||||
vol.Optional(CONF_SECURITY_PROTOCOL, default="PLAINTEXT"): vol.In(
|
||||
["PLAINTEXT", "SASL_SSL"]
|
||||
["PLAINTEXT", "SSL", "SASL_SSL"]
|
||||
),
|
||||
vol.Optional(CONF_USERNAME): cv.string,
|
||||
vol.Optional(CONF_PASSWORD): cv.string,
|
||||
|
@ -94,7 +94,7 @@ class KafkaManager:
|
|||
port: int,
|
||||
topic: str,
|
||||
entities_filter: EntityFilter,
|
||||
security_protocol: Literal["PLAINTEXT", "SASL_SSL"],
|
||||
security_protocol: Literal["PLAINTEXT", "SSL", "SASL_SSL"],
|
||||
username: str | None,
|
||||
password: str | None,
|
||||
) -> None:
|
||||
|
|
Loading…
Reference in New Issue