1. Напишите класс, который подписывается на все топики, которые появляются в Kafka
2. Напишите класс, который подписывается на все топики, но отписывается от слишком быстрых топиков (на основе чего можно оценить скорость программно?)