kafka Connect: Tasks.max больше, чем количество разделов, но в статусе написано RUNNING

Promise Reducer на помощь!

[1, 2, 3, 4].reduce((op, n) => {
    return op.then(filteredNs => {
        return new Promise(resolve => {
            setTimeout(() => {
                if (n >= 3) {
                    console.log("Keeping", n);
                    resolve(filteredNs.concat(n))
                } else {
                    console.log("Dropping", n);
                    resolve(filteredNs);
                }
            }, 1000);
        });
    });
}, Promise.resolve([]))
.then(filteredNs => console.log(filteredNs));

Редукторы потрясающие. «Уменьшите мою проблему до моей цели», похоже, является довольно хорошей стратегией для чего-либо более сложного, чем простые решения для вас, т. Е. Фильтрация массива вещей, которые не все доступны сразу.