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.