public void initialize(ConnectorContext ctx) {
        context = ctx;
    }
Initialize this connector, using the provided ConnectorContext to notify the runtime of
input configuration changes.
@param ctx context object used to interact with the Kafka Connect runtime
connect/api/src/main/java/org/apache/kafka/connect/connector/Connector.java