При запуске кластера Kafka (Kafka v 2.11-1.1.0) на 2 компьютерах с Windows кажется, что возникает исключение AccessDeniedException, когда я пытаюсь сменить лидера для определенного раздела темы.Это приводит к сбою брокера (текущего лидера).Это может быть связано со следующей нерешенной проблемой: https://issues.apache.org/jira/browse/KAFKA-1194.Могу ли я что-нибудь сделать по этому поводу, или вы можете просто не менять лидера темы в Windows без перезагрузки брокера?
Шаги для повторного создания:
- Запуск службы zookeeper на компьютере с Windows 10.
- Запуск брокера kafka на той же машине.
- Запуск второго брокера kafka на втором компьютере с Windows 10, подключенным ктот же зоопарк, что и первый, для формирования кластера Kafka.
- Создайте тему с 1 разделом и наблюдайте за результирующим лидером этого раздела.
Используйте kafka-reassign-команда разделов (согласно https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools), чтобы изменить заголовок для раздела темы. Используйте файл json, аналогичный показанному ниже, где «topicName» заменяется именем темы, созданной на шаге 4, и «1'заменяется на BrokerId брокера Kafka, который в настоящее время не является лидером этого раздела:
{
"version":1,
"partitions":[
{"topic":"topicName","partition":0,"replicas":[1]}
]
}
После выполнения описанных выше шагов я вижуФ.О.светящийся в журнале старый лидер раздела темы:
Error while renaming dir for testTopic in log dir C:\Users\Public\Documents\Kafka\logs\ (kafka.server.LogDirFailureChannel) java.nio.file.AccessDeniedException