Ik heb met dit probleem te maken gehad. Als er minder bronnen zijn om een SinkTask of SourceTask te starten, kan dit gebeuren.
Het geheugen dat aan de werknemer is toegewezen, kan enige tijd minder zijn. Werknemers krijgen standaard 250 MB toegewezen. Verhoog dit alstublieft. Hieronder ziet u een voorbeeld om 2 GB geheugen toe te wijzen aan de werknemer die in gedistribueerde modus werkt.
KAFKA_HEAP_OPTS="-Xmx2G" bij $KAFKA_SERVICE_HOME/connect-distributed $KAFKA_CONFIG_HOME/connect-avro-distributed.properties