Я недавно обновился с kafka 0.10.1 до 1.1.0. Мое потоковое приложение создает потоки, подписываясь...