KafkaConfiguration

class lsst.ts.salkafka.KafkaConfiguration(broker_url: str, registry_url: str, partitions: int, replication_factor: int, wait_for_ack: Union[int, str], sasl_plain_username: Union[None, str] = None, sasl_plain_password: Union[None, str] = None)

Bases: object

Kakfa producer configuration.

Parameters:

broker_urlstr

Kafka broker URL, without the transport. For example: my.kafka:9000

registry_urlstr

Schema Registry URL, including the transport. For example: https://registry.my.kafka/

partitionsint

Number of partitions for each Kafka topic.

replication_factorint

Number of replicas for each Kafka partition.

wait_for_ackint or str

The only allowd values are:

• 0: do not wait (unsafe)

• 1: wait for first kafka broker to respond (recommended)

• “all”: wait for all kafka brokers to respond

sasl_plain_usernameNone | str

username for SASL authentication. If specified then you must also specify sasl_plain_password. Default: None

sasl_plain_passwordstr

password for SASL authentication. If specified then you must also specify sasl_plain_username. Default: None

Attributes Summary

sasl_plain_password
sasl_plain_username

Attributes Documentation

sasl_plain_password: None | str = None

sasl_plain_username: None | str = None