提供 Kafka 集群管理功能，包括 Broker 信息查看、Topic 管理、Consumer Group 监控、消息发送等，并内置 WebSocket 实时推送的 Dashboard 大屏。

仓库坐标

Maven

<dependency>
    <groupId>com.luamas.thinkbridge</groupId>
    <artifactId>kafka-manger-spring-boot-starter</artifactId>
</dependency>

Gradle

implementation("com.luamas.thinkbridge:kafka-manger-spring-boot-starter")

配置

think:
  kafka:
    manger:
      # 是否启用，默认关闭
      enabled: true
      # 管理面板路径，默认 /kafka-manger
      path: /kafka-manger
      # 权限校验标识，默认 kafka_manger
      check-authority: kafka_manger
      # 是否使用自定义认证
      use-custom-auth: false
      # 访问用户配置
      user:
        username: kafka_manger
        # 明文密码，或加前缀的加密密码
        password: "{noop}kafka_manger"
      # ZooKeeper 配置（可选）
      zoo-keeper:
        enabled: false
        bootstrap-servers: localhost:2181
        session-timeout: 25000
      # Kafka 配置
      kafka:
        bootstrap-servers: localhost:9092
        jmx-port: 9999
        properties:
          enable.auto.commit: false

配置属性一览

属性

默认值

说明

think.kafka.manger.enabled

false

是否启用Kafka管理

think.kafka.manger.path

/kafka-manger

管理面板访问路径

think.kafka.manger.check-authority

kafka_manger

权限校验标识

think.kafka.manger.use-custom-auth

false

是否使用自定义认证

think.kafka.manger.user.username

kafka_manger

访问用户名

think.kafka.manger.user.password

{noop}kafka_manger

访问密码

think.kafka.manger.zoo-keeper.enabled

false

是否启用ZooKeeper连接

think.kafka.manger.zoo-keeper.bootstrap-servers

localhost:2181

ZooKeeper地址

think.kafka.manger.kafka.bootstrap-servers

localhost:9092

Kafka地址

think.kafka.manger.kafka.jmx-port

9999

JMX端口

功能特性

  • 集群信息：Broker 列表、Controller 节点、Topic 总数

  • Topic 管理：创建、删除、查看分区和消息数

  • Consumer Group：查看消费者组偏移量

  • 消息发送：向指定 Topic 发送测试消息

  • Dashboard 大屏：通过 WebSocket 实时推送集群状态