BaseSource
.init_client
: Initialize the client used to connect to the source.batch_read
: Batch read messages from the source and use handler
method to process the messages.BaseSink
.init_client
: Initialize the client used to connect to the destination.batch_write
: Batch write messages to destination.