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.