Я очень плохо знаком с Кафкой. Так что этот вопрос может быть очень простым. Чего я пытаюсь добиться, так это выяснить время, необходимое для перебалансировки, когда брокер терпит неудачу, а затем снова добавляется. Из моего чтения документации (http://kafka.apache.org/documentation/#basic_ops_restarting). Когда брокер выходит из строя или закрыт на техническое обслуживание
It will sync all its logs to disk to avoid needing to do any log recovery when it restarts (i.e. validating the checksum for all messages in the tail of the log). Log recovery takes time so this speeds up intentional restarts.It will migrate any partitions the server is the leader for to other replicas prior to shutting down. This will make the leadership transfer faster and minimize the time each partition is unavailable to a few milliseconds.
Что я хочу сделать, так это узнать время, затраченное на migrate any partitions that the server is the leader for to other replicas
Моя настройка kafka — это 3 узла брокера и 3 узла zk.
Кроме того, когда я добавляю этот узел обратно в свойство auto.rebalance=true, снова срабатывает перебалансировка, и он переизбирает лидера. Как мне измерить и это время?
