Ich habe dieses Problem konfrontiert. Wenn die Ressourcen zum Starten einer SinkTask oder SourceTask geringer sind, kann dies passieren.
Der dem Worker zugewiesene Speicher kann einige Zeit geringer sein. Standardmäßig werden Arbeitern 250 MB zugewiesen. Bitte erhöhen Sie diese. Unten sehen Sie ein Beispiel für die Zuweisung von 2 GB Arbeitsspeicher für den Worker, der im verteilten Modus ausgeführt wird.
KAFKA_HEAP_OPTS="-Xmx2G" sh $KAFKA_SERVICE_HOME/connect-distributed $KAFKA_CONFIG_HOME/connect-avro-distributed.properties
