Сблъсквал съм се с този проблем. Ако ресурсите са по-малко за стартиране на SinkTask или SourceTask, това може да се случи.
Паметта, разпределена за работника, може да бъде по-малко известно време. По подразбиране на работниците се разпределят 250MB. Моля, увеличете това. По-долу е даден пример за разпределяне на 2 GB памет за работния файл, работещ в разпределен режим.
KAFKA_HEAP_OPTS="-Xmx2G" sh $KAFKA_SERVICE_HOME/connect-distributed $KAFKA_CONFIG_HOME/connect-avro-distributed.properties
