Zmierzyłem się z tym problemem. Jeśli zasoby są mniejsze do uruchomienia SinkTask lub SourceTask, może się to zdarzyć.
Pamięć przydzielona pracownikowi może być przez jakiś czas mniej. Domyślnie pracownikom przydzielane jest 250 MB. Proszę, zwiększ to. Poniżej znajduje się przykład alokacji 2 GB pamięci dla pracownika działającego w trybie rozproszonym.
KAFKA_HEAP_OPTS="-Xmx2G" sh $KAFKA_SERVICE_HOME/connect-distributed $KAFKA_CONFIG_HOME/connect-avro-distributed.properties
