Micronaut应用程序无法访问Kubernetes配置映射中的值

Question

我使用Micronaut 3.2.3和Kubernetes集成，从配置映射和机密中注入配置值。

依赖：

    implementation("io.micronaut.kubernetes:micronaut-kubernetes-client")
    implementation("io.micronaut.kubernetes:micronaut-kubernetes-discovery-client")

bootstrap.yml

micronaut:
  application:
    name: ingestor
  config-client:
    enabled: true

kubernetes:
  client:
    config-maps:
      enabled: true
      includes:
        - application
        - ingestor
    secrets:
      enabled: true
      includes:
        - application
        - ingestor

如您所见，应用程序配置图包括kafka.brokers值:

kubectl get configmaps application -o yaml   
  
apiVersion: v1
data:
  application.yml: |
    kafka.brokers: xxx

kubectl get configmaps ingestor -o yaml   
  
apiVersion: v1
data:
  application.yml: |
    prop1: value1

我添加了一个简单的单例类，用于检查是否可以注入项目：

@Singleton
class SomeConfiguration(@Value("\${kafka.brokers}") private val kafkaBrokers: String) {

    init {
        println(kafkaBrokers)
    }

}

日志跟踪似乎表明这些配置映射已被正确访问：

15:59:24.206 [OkHttp https://10.222.0.1/...] -  -   DEBUG i.m.k.c.KubernetesConfigurationClient - Adding config map with name application
15:59:24.218 [OkHttp https://10.222.0.1/...] -  -   DEBUG i.m.k.c.KubernetesConfigurationClient - Adding config map with name ingestor

但是，应用程序崩溃，因为它找不到它：

fun main(args: Array<String>) {
    build()
        .args(*args)
        .eagerInitSingletons(true)

15:59:25.484 [main] -  -   ERROR io.micronaut.runtime.Micronaut - Error starting Micronaut server: Bean definition [xxx.SomeConfiguration] could not be loaded: Failed to inject value for parameter [kafkaBrokers] of class: xxx.configuration.SomeConfiguration

Message: Failed to inject value for parameter [kafkaBrokers] of class: xxx.configuration.SomeConfiguration

Message: Error resolving property value [${kafka.brokers}]. Property doesn't exist

Answer 1

这个问题有点棘手。关键是配置映射中使用的yml文件的名称，应用程序和摄取器配置映射都将其定义为application.yml：

apiVersion: v1
data:
  application.yml: |

它们不能重叠，因此我将摄取器配置映射更改为：

kubectl get configmaps ingestor -o yaml   
  
apiVersion: v1
data:
  ingestor.yml: |
    prop1: value1

现在是<代码>Kafka。找到并注入brokers值。