Jag har ställts inför denna fråga. Om resurserna är mindre för en SinkTask eller SourceTask att starta kan detta hända.
Minne som tilldelas arbetstagaren kan vara mindre under en viss tid. Som standard tilldelas arbetare 250 MB. Öka detta. Nedan är ett exempel för att tilldela 2 GB minne för arbetaren som körs i distribuerat läge.
KAFKA_HEAP_OPTS="-Xmx2G" sh $KAFKA_SERVICE_HOME/connect-distributed $KAFKA_CONFIG_HOME/connect-avro-distributed.properties