Jeg har stået over for dette problem. Hvis ressourcerne er mindre for en SinkTask eller SourceTask at starte, kan dette ske.
Hukommelse tildelt til arbejderen kan være kortere et stykke tid. Som standard tildeles arbejdere 250 MB. Øg venligst dette. Nedenfor er et eksempel på tildeling af 2 GB hukommelse til arbejderen, der kører i distribueret tilstand.
KAFKA_HEAP_OPTS="-Xmx2G" sh $KAFKA_SERVICE_HOME/connect-distributed $KAFKA_CONFIG_HOME/connect-avro-distributed.properties