Весеннее облако Кафки в ручьях связующего здоровья "НЕИЗВЕСТНО" - PullRequest
Новая
       40

Весеннее облако Кафки в ручьях связующего здоровья "НЕИЗВЕСТНО"

0 голосов
/ 11 октября 2019

Мы используем версию 2.1.3 для потоков потока kafka весеннего облака - 

      <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"
        }
      }
    }

Ценю любую помощь по этому вопросу.

1 Ответ

2 голосов
/ 14 октября 2019

Показатели работоспособности для связующих семейства Kafka Streams вошли только в строку 2,2. Есть ли шанс, что вы сможете перейти на 2.2 с 2.1.3? Здесь - это приложение, в котором работают показатели здоровья. Это использует снимки 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.

...