Skip to content

AdminClientConnectionParams

faststream.kafka.schemas.params.AdminClientConnectionParams #

Bases: TypedDict

A class to represent the connection parameters for an admin client.

bootstrap_servers instance-attribute #

bootstrap_servers: str | list[str]

loop instance-attribute #

loop: AbstractEventLoop | None

client_id instance-attribute #

client_id: str

request_timeout_ms instance-attribute #

request_timeout_ms: int

retry_backoff_ms instance-attribute #

retry_backoff_ms: int

metadata_max_age_ms instance-attribute #

metadata_max_age_ms: int

security_protocol instance-attribute #

security_protocol: Literal['SSL', 'PLAINTEXT']

api_version instance-attribute #

api_version: str

connections_max_idle_ms instance-attribute #

connections_max_idle_ms: int

sasl_mechanism instance-attribute #

sasl_mechanism: Literal[
    "PLAIN",
    "GSSAPI",
    "SCRAM-SHA-256",
    "SCRAM-SHA-512",
    "OAUTHBEARER",
]

sasl_plain_password instance-attribute #

sasl_plain_password: str

sasl_plain_username instance-attribute #

sasl_plain_username: str

sasl_kerberos_service_name instance-attribute #

sasl_kerberos_service_name: str

sasl_kerberos_domain_name instance-attribute #

sasl_kerberos_domain_name: str

ssl_context instance-attribute #

ssl_context: SSLContext

sasl_oauth_token_provider instance-attribute #

sasl_oauth_token_provider: AbstractTokenProvider