我把我的应用程序从 Spring Boot 2.0.0.M6
至 Spring Boot 2.0.0.RC2
遇到了这个问题 KafkaHealthIndicator
我现在认为我的Kafka身份是 DOWN
.
kafka":{
"status":"DOWN",
"details":{
"clusterId":"wpAKGc_DQBWy9YfPTLNctQ",
"brokerId":"0",
"nodes":1
}
}
``` `org.springframework.boot.actuate.kafka.KafkaHealthIndicator` 使用以下逻辑确定状态:
Status status = nodes >= replicationFactor ? Status.UP : Status.DOWN;
其中复制因子由以下属性检索: `transaction.state.log.replication.factor` 我已经添加了以下属性到我的Kafka `server.properties` :
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1
但没用。
我做错了什么?如何解决?
现在,我使用时态解决方案来禁用kafka的healthcheck:
management.health.kafka.enabled=false
但我不喜欢它,我想修复它。
1条答案
按热度按时间at0kjp5o1#
这对我来说很好。。。
具有
和
更改属性后是否重新启动了代理?