在两台windows机器上运行kafka集群(kafka v 2.11-1.1.0)时,当我尝试更改特定主题分区的前导时,似乎抛出了accessdeniedexception。这会导致代理(当前领导)崩溃。这可能与以下未解决的问题有关:https://issues.apache.org/jira/browse/kafka-1194 . 我能做些什么吗?或者你能不能在不重新启动代理的情况下暂时不改变windows上的主题标题?
重新生产步骤:
在windows 10计算机上启动zookeeper服务。
在同一台机器上启动Kafka代理。
在与第一台zookeeper连接的第二台windows10机器上启动第二个kafka代理,形成kafka集群。
创建一个具有1个分区的主题,并观察该分区的结果引线。
使用kafka重新分配分区命令(根据https://cwiki.apache.org/confluence/display/kafka/replication+tools)更改该主题分区的引线。使用类似于下面所示的json文件,其中“topicname”替换为步骤4中创建的主题的名称,“1”替换为kafka代理的brokerid,该代理当前不是此分区的领导者: { "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
暂无答案!
目前还没有任何答案,快来回答吧!