Spring Boot是否支持将Kafka指标通过OpenTelemetry发送至Grafana可视化？

Spring Boot完全支持将Kafka生产/消费相关指标发送到OpenTelemetry Collector，具体实现思路如下：

1. 依赖配置 #

在pom.xml（Maven）或build.gradle（Gradle）中添加必要依赖：

• OpenTelemetry Spring Boot starter
• Spring Boot Actuator（自带Kafka指标收集能力）

示例Maven依赖：

<dependency>
    <groupId>io.opentelemetry.instrumentation</groupId>
    <artifactId>opentelemetry-spring-boot-starter</artifactId>
    <version>1.32.0</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

2. 配置指标导出 #

在application.properties或application.yml中配置OpenTelemetry Collector的地址及相关参数：

# 启用OpenTelemetry指标导出
management.opentelemetry.metrics.export.enabled=true
# 指定Collector的指标接收端点
management.opentelemetry.metrics.export.endpoint=http://your-otel-collector:4318/v1/metrics
# 设置服务标识，方便Grafana中区分不同应用
management.opentelemetry.resource.attributes=service.name=your-kafka-app

3. 核心Kafka指标自动收集 #

Spring Boot Actuator默认会收集Kafka生产者和消费者的核心指标，无需额外编码，比如：

• kafka.producer.record.send.total：累计发送消息数
• kafka.consumer.record.received.total：累计接收消息数
• kafka.producer.record.error.total：累计发送错误数
• kafka.consumer.record.error.total：累计消费错误数

这些指标会被OpenTelemetry自动捕获并导出到Collector，后续可在Grafana中对接Collector的数据源（如配置了Prometheus导出的Collector）完成可视化。

4. 自定义指标扩展（可选） #

如果需要特定业务场景的Kafka指标，可通过MeterRegistry手动创建并注册指标（比如特定主题的消息延迟、分区消费速率等），OpenTelemetry会自动将这些自定义指标一并导出。

内容的提问来源于stack exchange，提问作者user1834664