ConnectorConfig

class kafkaconnect.config.ConnectorConfig

Bases: ABC

Connector configuration interface.

Methods Summary

asjson()	Convert dataclass instance into JSON.
format_field_names(fields)	Rename a field name by replacing '_' with '.'.
update_config(topics)	Update connector configuration.

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_config(topics: Set[str]) → None

Update connector configuration.

Abstract method to be implemented by subclasses.