Saya telah menghadapi masalah ini. Jika sumber daya kurang untuk memulai SinkTask atau SourceTask, ini bisa terjadi.
Memori yang dialokasikan untuk pekerja mungkin kurang beberapa waktu. Secara default pekerja dialokasikan 250MB. Tolong tingkatkan ini. Di bawah ini adalah contoh untuk mengalokasikan memori 2GB untuk pekerja yang berjalan dalam mode terdistribusi.
KAFKA_HEAP_OPTS="-Xmx2G" sh $KAFKA_SERVICE_HOME/connect-distributed $KAFKA_CONFIG_HOME/connect-avro-distributed.properties