EFAK icon indicating copy to clipboard operation
EFAK copied to clipboard

5.0问题汇总

Open hjun881 opened this issue 2 months ago • 6 comments

  1. ke.sql有问题,很多create 创建sql语句结尾没有;号导致source ke.sql报错
  2. ke.sql里没有ke_task_scheduler表的建表语句导致启动时报没有ke_task_scheduler
  3. 初始登陆时admin/admin123密码不对, 密码并不是admin123
  4. 进入平台后打开集群管理直接报错,大概率是因为新部署的efak平台没有添加任何kafka集群登陆页面报错,可是页面上也没有添加kafka集群的按钮如果添加kafka集群?

hjun881 avatar Oct 11 '25 08:10 hjun881

Image Image

怎么添加kafka集群呀,愁死我了,也没有文档页面上也没有添加集群按钮

hjun881 avatar Oct 11 '25 10:10 hjun881

下载了最新的代码, 首页会显示创建集群按钮,当填写一个broker后创建集群按钮自动消息了无法再调出创建集群按钮。 并且新加的那个节点状态一直是离线,等几10分钟还是离线状态。 bug太多,放弃了。还是用cmak省心

hjun881 avatar Oct 12 '25 03:10 hjun881

  1. ke.sql有问题,很多create 创建sql语句结尾没有;号导致source ke.sql报错
  2. ke.sql里没有ke_task_scheduler表的建表语句导致启动时报没有ke_task_scheduler
  3. 初始登陆时admin/admin123密码不对, 密码并不是admin123
  4. 进入平台后打开集群管理直接报错,大概率是因为新部署的efak平台没有添加任何kafka集群登陆页面报错,可是页面上也没有添加kafka集群的按钮如果添加kafka集群?

密码不对,自己写了个测试类来更新admin的密码

package org.kafka.eagle.web.util;package org.kafka.eagle.web.util;

import org.junit.jupiter.api.Test;
import org.kafka.eagle.dto.user.UserInfo;
import org.kafka.eagle.web.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.time.LocalDateTime;

import static org.junit.jupiter.api.Assertions.*;

/**
 * TaskUtils测试类
 */
@SpringBootTest
public class UpdateAdminPasswdTest {
    @Autowired
    private UserService userService;
    @Test
    public void testUpdatePassword() {
        UserInfo userInfo = new UserInfo();
        userInfo.setId(1L);
        userInfo.setUsername("admin");
        userInfo.setOriginPassword("$2a$10$92IXUNpkjO0rOQ5byMi.Ye4oKoEa3Ro9llC/.og/at2.uheWG/igi");
        userInfo.setRoles("ADMIN");
        userInfo.setStatus("ACTIVE");
        userInfo.setModifyTime(LocalDateTime.now());
        String newPassword = "admin123";
//        String newPassword = "abc.1234";
        String encryptedPassword = org.springframework.security.crypto.bcrypt.BCrypt.hashpw(newPassword,
                org.springframework.security.crypto.bcrypt.BCrypt.gensalt());
        userInfo.setPassword(encryptedPassword);
        userService.resetPassword(userInfo);
    }
}

实际上密码admin123对应的加密后存储在数据库的密码应该为$2a$10$Dps2LMtLQH/dX3q/JVH4V..m707LfGnAxLFG1sIbIxD7zAjK3hFFC

dyeaster avatar Oct 12 '25 09:10 dyeaster

重置密码地址: http://localhost:8080/password-tool

smartloli avatar Oct 13 '25 14:10 smartloli

想了解下,3.0.1版本看不到kafka消费堆积情况,在这个版本是否有解决呀

hawkwean avatar Oct 21 '25 02:10 hawkwean

5.0 会支持kraft吗

ivancxj avatar Nov 04 '25 07:11 ivancxj