obsidiandynamics/kafdrop Docker 镜像 - 轩辕镜像

Kafdrop Docker镜像

Kafdrop Docker镜像是Kafdrop的官方镜像，Kafdrop是一个用于监控Apache Kafka集群的Web UI工具。该工具可显示代理（brokers）、主题（topics）、分区（partitions）、消费者（包括延迟）等信息，并允许查看消息。

!概览截图

Kafdrop支持JDK 11+、Kafka 2.x、Helm和Kubernetes，是一款轻量级应用，运行于Spring Boot之上，配置极其简单，支持SASL和TLS安全代理连接。

运行

sh
docker run -d --rm -p 9000:9000 \
    -e KAFKA_BROKERCONNECT=host:port,host:port \
    -e JVM_OPTS="-Xms32M -Xmx64M" \
    -e SERVER_SERVLET_CONTEXTPATH="/" \
    obsidiandynamics/kafdrop:latest

然后通过http://localhost:9000访问UI。

注意：从Kafdrop 3.10.0开始，不再需要ZooKeeper连接。所有必要的集群信息均通过Kafka admin API获取。

环境变量

• KAFKA_BROKERCONNECT：Kafka主机/端口对的引导列表。
• JVM_OPTS：JVM选项。
• JMX_PORT：用于JMX的端口。无默认值；若未指定，JMX将不被暴露。
• HOST：RMI注册表报告的主机名（用于JMX）。默认值：localhost。
• SERVER_PORT：Web服务器监听端口。默认值：9000。
• SERVER_SERVLET_CONTEXTPATH：用于处理请求的上下文路径（必须以/结尾）。默认值：/。
• KAFKA_PROPERTIES：用于配置代理连接的附加属性（base64编码）。
• KAFKA_TRUSTSTORE：代理认证证书（base64编码）。TLS/SSL必需。
• KAFKA_KEYSTORE：双向TLS认证的私钥（base64编码）。

连接到安全代理

Kafdrop支持TLS（SSL）和SASL连接，用于加密和认证。可通过提供以下文件的组合进行配置：

• 信任库（Truststore）：若启用TLS，指定用于认证代理的证书。
• 密钥库（Keystore）：若需要双向TLS认证，指定用于客户端向代理认证的私钥。
• 属性文件：指定必要配置，包括密钥库/信任库密码、密码套件、启用的TLS协议版本、用户名/密码对等。提供信任库和/或密钥库文件时，ssl.truststore.location和ssl.keystore.location属性将自动分配。

这些文件通过环境变量以base64编码形式提供：

sh
docker run -d --rm -p 9000:9000 \
    -e KAFKA_BROKERCONNECT=host:port,host:port \
    -e KAFKA_PROPERTIES=$(cat kafka.properties | base64) \
    -e KAFKA_TRUSTSTORE=$(cat kafka.truststore.jks | base64) \   # 可选
    -e KAFKA_KEYSTORE=$(cat kafka.keystore.jks | base64) \       # 可选
    obsidiandynamics/kafdrop

提示！ 我们希望您喜欢Kafdrop！请花点时间⭐GitHub仓库或发推文分享。