2 - 3 partitions. Для джоина кол-во партиций должно быть одинаковым. Есть ли способ сделать репартишн Topic 1 чтобы у него были 3 партиции?
В 2.6 появился repartition метод. В других версиях делаешь топит руками и потом through()
Обсуждают сегодня