Eu enfrentei esse problema. Se os recursos forem menores para um SinkTask ou SourceTask iniciar, isso pode acontecer.

A memória alocada para o trabalhador pode demorar menos. Por padrão, os trabalhadores recebem 250 MB. Por favor, aumente isso. Abaixo está um exemplo para alocar 2 GB de memória para o trabalhador em execução no modo distribuído.

KAFKA_HEAP_OPTS="-Xmx2G" sh $KAFKA_SERVICE_HOME/connect-distributed $KAFKA_CONFIG_HOME/connect-avro-distributed.properties