партиций. 
                  
                  
                  Есть спарк джоба, которая его читает и просто перекладывает в куду.
                  
                  
                  Джоба эта на кластере имеет 15 экзекуторов.
                  
                  
                  Все работает хорошо.
                  
                  
                  Вопросы такие.
                  
                  
                  Если 15 экзекуторов и 15 партиций, должно быть на каждом экзекуторе по консьюмеру, правильно ?
                  
                  
                  Если да, почему в веб-морде кафки ([вот такая](https://akhq.io)) во вкладке consumer_groups  соответствующего топика я вижу в группе только 1 мембера, 1 ip, хотя экзекуторы работают на разных нодах, как видно из морды спарка?
                  
                  
                
если есть доступ к портам брокера, начни с того что чекни через кафковские тулы: ./kafka-consumer-groups.sh --bootstrap-server broker01.example.com:9092 --describe --group mygroupname
Спасибо. Но нет доступа )
Обсуждают сегодня