ConnectorConfig

class kafkaconnect.config.ConnectorConfig

Bases: object

Connector configuration interface.

Methods Summary

asjson()

Convert dataclass instance into JSON.

format_field_names(fields)

Rename a field name by replacing '_' with '.'.

update_topics(topics)

update_topics() abstract method.

Methods Documentation

asjson() str

Convert dataclass instance into JSON.

static format_field_names(fields: List[Tuple[str, Any]]) Dict[str, str]

Rename a field name by replacing ‘_’ with ‘.’.

Dictionary factory used with the dataclasses.asdict() method.

abstract update_topics(topics: Set[str]) None

update_topics() abstract method.