public void initialize(SinkTaskContext context) {
        this.context = context;
    }
Initialize the context of this task. Note that the partition assignment will be empty until
Connect has opened the partitions for writing with {@link #open(Collection)}.
@param context The sink task's context
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java