KafkaConn

classView source ↗

class KafkaConn(
    servers: KafkaServersSpec,
    credentials: KafkaCredentialsSpec,
    group_id: str | None = None,
    schema_registry: SchemaRegistrySpec | None = None,
    enforce_connection_params: bool = True,
    cx_src_configs: dict | None = None,
)

Bases: Conn

Categories: connections

Kafka Consumer Connection configuration.

Initialize a KafkaConn instance.

Parameters

parameter

servers

Kafka bootstrap servers.

parameter

credentials

Optional Kafka credentials.

parameter

group_id

Optional Kafka consumer group ID.

parameter

schema_registry

Optional Kafka schema registry configuration.

parameter

enforce_connection_params

Whether to enforce connection parameters for the Kafka connection.

parameter

cx_src_configs

Source-specific configuration parameters for the Kafka connection. Defaults to None.

Properties

property

credentialsKafkaCredentialsSpec

Kafka credentials.

property

cx_src_configsdict

Source-specific configuration parameters for the Kafka connection.

property

enforce_connection_paramsbool

Whether to enforce connection parameters.

property

group_idstr | None

Kafka consumer group ID.

property

schema_registrySchemaRegistrySpec | None

Kafka schema registry configuration.

property

serversKafkaServersSpec

Kafka bootstrap servers.