Custom Destination

InferenceDB uses destinations in order to create Kafka Connect connectors to different data targets.

As an example, see ConfluentS3Destination.

@destination("custom")
class MyDestination(Destination):
    def __init__(self, logger_name: str, topic: str, config: Dict[str, Any]):
        self._logger_name = logger_name
        self._topic = topic
        self._config = config

    async def create_connector(self):
        ...