Tôi đã phải đối mặt với vấn đề này. Nếu tài nguyên ít hơn để SinkTask hoặc SourceTask bắt đầu, điều này có thể xảy ra.
Bộ nhớ được cấp cho công nhân có thể ít hơn một chút. Theo mặc định, công nhân được phân bổ 250MB. Hãy tăng điều này lên. Dưới đây là một ví dụ để cấp phát bộ nhớ 2GB cho công nhân đang chạy ở chế độ phân tán.
KAFKA_HEAP_OPTS ="- Xmx2G" sh $ KAFKA_SERVICE_HOME / kết nối-phân phối $ KAFKA_CONFIG_HOME / connect-avro-distributed.properties
