@Deprecated
    public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
    }
@deprecated Use {@link #open(Collection)} for partition initialization.
connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java