Spring cloud Kafka streams活页夹健康状况“未知”

Question

我们使用2.1.3版本的spring cloud stream kafka streams -

      <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-stream-binder-kafka-streams</artifactId>
        <version>2.1.3.RELEASE</version>
      </dependency>
      <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-stream-binder-kafka-core</artifactId>
        <version>2.1.3.RELEASE</version>
      </dependency>
      <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-stream-kafka</artifactId>
        <version>2.1.3.RELEASE</version>
      </dependency>

application.yml具有属性集-

management.health.binders.enabled = true
management.health.kafka.enabled = true

但是卡夫卡活页夹的状态仍然是未知的-

"binders": {
      "status": "UNKNOWN",
      "details": {
        "ktable": {
          "status": "UNKNOWN"
        },
        "kstream": {
          "status": "UNKNOWN"
        },
        "globalktable": {
          "status": "UNKNOWN"
        }
      }
    }

感谢大家在这方面的帮助。

Answer 1

Kafka Streams系列粘合剂的健康指标仅为2.2。你有没有可能从2.1.3升级到2.2？Here是一个健康指示器正常工作的应用程序。这是使用3.0的快照，但2.2也应该可以工作。运行此应用程序时，我得到的输出如下所示。

curl --silent http://localhost:8080/actuator/health/ | jq .
{
  "status": "UP",
  "components": {
    "binders": {
      "status": "UP",
      "components": {
        "globalktable": {
          "status": "UP",
          "details": {
            "threadState": "RUNNING",
            "standbyTasks": {},
            "activeTasks": {
              "partitions": [
                "partition=0, topic=process-applicationId-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition"
              ],
              "taskId": "1_0"
            },
            "threadName": "process-applicationId-fa4e65eb-6060-43f0-94eb-4c4bf1497613-StreamThread-1"
          }
        },
        "kstream": {
          "status": "UP",
          "details": {
            "threadState": "RUNNING",
            "standbyTasks": {},
            "activeTasks": {
              "partitions": [
                "partition=0, topic=process-applicationId-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition"
              ],
              "taskId": "1_0"
            },
            "threadName": "process-applicationId-fa4e65eb-6060-43f0-94eb-4c4bf1497613-StreamThread-1"
          }
        },
        "ktable": {
          "status": "UP",
          "details": {
            "threadState": "RUNNING",
            "standbyTasks": {},
            "activeTasks": {
              "partitions": [
                "partition=0, topic=process-applicationId-KSTREAM-AGGREGATE-STATE-STORE-0000000003-repartition"
              ],
              "taskId": "1_0"
            },
            "threadName": "process-applicationId-fa4e65eb-6060-43f0-94eb-4c4bf1497613-StreamThread-1"
          }
        }
      }
    },
    "diskSpace": {
      "status": "UP",
      "details": {
       ...
      }
    },
    "ping": {
      "status": "UP"
    }
  }
}

注意-以下注释中提到的未显示多处理器运行状况信息的问题将在活页夹(3.0.0)的最新快照中解决，并将作为RC1的一部分提供。