public interface Source<T> extends AutoCloseable {     /**     * Open connector with configuration.     *     * @param config initialization config     * @param sourceContext environment where the source connector is running     * @throws Exception IO type exceptions when opening a connector     */    void open(final Map<String, Object> config, SourceContext sourceContext) throws Exception;     /**     * Reads the next message from source.     * If source does not have any new messages, this call should block.     * @return next message from source.  The return result should never be null     * @throws Exception     */    Record<T> read() throws Exception;}

public interface BatchSource<T> extends AutoCloseable {     /**     * Open connector with configuration.     *     * @param config config that's supplied for source     * @param context environment where the source connector is running     * @throws Exception IO type exceptions when opening a connector     */    void open(final Map<String, Object> config, SourceContext context) throws Exception;     /**     * Discovery phase of a connector.  This phase will only be run on one instance, i.e. instance 0, of the connector.     * Implementations use the taskEater consumer to output serialized representation of tasks as they are discovered.     *     * @param taskEater function to notify the framework about the new task received.     * @throws Exception during discover     */    void discover(Consumer<byte[]> taskEater) throws Exception;     /**     * Called when a new task appears for this connector instance.     *     * @param task the serialized representation of the task     */    void prepare(byte[] task) throws Exception;     /**     * Read data and return a record     * Return null if no more records are present for this task     * @return a record     */    Record<T> readNext() throws Exception;}

public interface Sink<T> extends AutoCloseable {    /**     * Open connector with configuration.     *     * @param config initialization config     * @param sinkContext environment where the sink connector is running     * @throws Exception IO type exceptions when opening a connector     */    void open(final Map<String, Object> config, SinkContext sinkContext) throws Exception;     /**     * Write a message to Sink.     *     * @param record record to write to sink     * @throws Exception     */    void write(Record<T> record) throws Exception;}