Čelil jsem tomuto problému. Pokud jsou zdroje pro spuštění SinkTask nebo SourceTask méně, může se to stát.
Paměť přidělená pracovníkovi může být o nějakou dobu kratší. Ve výchozím nastavení mají pracovníci přiděleno 250 MB. Prosím, zvyšte toto. Níže je uveden příklad přidělení 2 GB paměti pro pracovníka běžícího v distribuovaném režimu.
KAFKA_HEAP_OPTS="-Xmx2G" sh $KAFKA_SERVICE_HOME/connect-distributed $KAFKA_CONFIG_HOME/connect-avro-distributed.properties