Ho affrontato questo problema. Se le risorse sono inferiori per l'avvio di un SinkTask o SourceTask, ciò può accadere.
La memoria allocata al lavoratore potrebbe essere inferiore per un po' di tempo. Per impostazione predefinita, ai lavoratori vengono assegnati 250 MB. Si prega di aumentare questo. Di seguito è riportato un esempio per allocare 2 GB di memoria per il lavoratore in esecuzione in modalità distribuita.
KAFKA_HEAP_OPTS="-Xmx2G" per $KAFKA_SERVICE_HOME/connect-distributed $KAFKA_CONFIG_HOME/connect-avro-distributed.properties
