J'ai été confronté à ce problème. Si les ressources sont moindres pour démarrer une SinkTask ou une SourceTask, cela peut arriver.
La mémoire allouée au travailleur peut être inférieure un certain temps. Par défaut, les travailleurs se voient allouer 250 Mo. Veuillez l'augmenter. Vous trouverez ci-dessous un exemple pour allouer 2 Go de mémoire au nœud de calcul exécuté en mode distribué.
KAFKA_HEAP_OPTS="-Xmx2G" sh $KAFKA_SERVICE_HOME/connect-distributed $KAFKA_CONFIG_HOME/connect-avro-distributed.properties
