Я написал потоковое приложение для обсуждения темы на кластере из 5 брокеров с 10 разделами. Я попробовал несколько комбинаций здесь, например, 10 экземпляров приложения (на 10 разных машинах) с 1 потоком каждый, 5 экземпляров с 2 потоками каждый. Но по какой-то причине, когда я проверяю в менеджере kafka, отображение 1: 1 между разделом и потоком потока не происходит. Некоторые потоки выбирают 2 раздела, а некоторые - нет. Можете ли вы помочь мне с тем же ?? Все темы являются частью одной группы и подписаны только на одну тему.
Используемая нами версия потоков kafka - 0.11.0.2, версия брокера - 0.10.0.2
.
Спасибо за вашу помощь