如何在Camel-K的Integration、Pipe、Kamelet中引用ConfigMap？

Camel-K Operator没有提供直接的spec.configmap字段来自动将自定义ConfigMap内容追加到user.properties，但可以通过以下几种方式实现配置引用，避免硬编码：

1. Java编写的Integration资源 #

方法1：挂载ConfigMap为环境变量并在路由中引用 #

通过volumes和volumeMounts将ConfigMap挂载到容器，路由中可通过Camel的env:前缀读取环境变量，或直接读取挂载的配置文件：

apiVersion: camel.apache.org/v1
kind: Integration
metadata:
  name: my-integration
spec:
  volumes:
    - name: my-config
      configMap:
        name: my-custom-configmap
  volumeMounts:
    - name: my-config
      mountPath: /etc/config
  sources:
    - content: |
        import org.apache.camel.builder.RouteBuilder;
        public class MyRoute extends RouteBuilder {
          @Override
          public void configure() throws Exception {
            // 引用环境变量
            from("timer:tick")
              .setBody().simple("Kafka Bootstrap: ${env.KAFKA_BOOTSTRAP_SERVERS}")
              .to("log:info");
            
            // 读取挂载的配置文件
            from("file:/etc/config?fileName=app.properties")
              .log("Config content: ${body}");
          }
        }

方法2：用Camel-K属性引用语法直接关联ConfigMap #

在spec.properties中声明引用规则，路由中通过{{key}}读取对应值：

apiVersion: camel.apache.org/v1
kind: Integration
metadata:
  name: my-integration
spec:
  properties:
    kafka.bootstrap.servers: "{{configmap:my-custom-configmap/kafka.bootstrap.servers}}"
  sources:
    - content: |
        import org.apache.camel.builder.RouteBuilder;
        public class MyRoute extends RouteBuilder {
          @Override
          public void configure() throws Exception {
            from("timer:tick")
              .setBody().simple("Kafka Bootstrap: {{kafka.bootstrap.servers}}")
              .to("log:info");
          }
        }

2. YAML编写的Pipe资源 #

方法1：在properties中直接引用ConfigMap属性 #

使用Camel-K的属性引用语法，直接关联ConfigMap的key：

apiVersion: camel.apache.org/v1
kind: Pipe
spec:
  sink:
    properties:
      bootstrapServers: "{{configmap:my-custom-configmap/kafka.bootstrap.servers}}"
      topic: "{{configmap:my-custom-configmap/kafka.topic}}"
    ref:
      apiVersion: camel.apache.org/v1alpha1
      kind: Kamelet
      name: kafka-not-secured-sink

方法2：通过环境变量批量加载ConfigMap #

将ConfigMap的key转为环境变量，再在properties中引用：

apiVersion: camel.apache.org/v1
kind: Pipe
spec:
  env:
    - name: KAFKA_BOOTSTRAP_SERVERS
      valueFrom:
        configMapKeyRef:
          name: my-custom-configmap
          key: kafka.bootstrap.servers
    - name: KAFKA_TOPIC
      valueFrom:
        configMapKeyRef:
          name: my-custom-configmap
          key: kafka.topic
  sink:
    properties:
      bootstrapServers: "${env:KAFKA_BOOTSTRAP_SERVERS}"
      topic: "${env:KAFKA_TOPIC}"
    ref:
      apiVersion: camel.apache.org/v1alpha1
      kind: Kamelet
      name: kafka-not-secured-sink

3. YAML编写的Kamelet资源 #

Kamelet作为复用组件，建议在实例化时传入ConfigMap值，而非硬编码到Kamelet定义中：

步骤1：定义带占位符的Kamelet #

apiVersion: camel.apache.org/v1alpha1
kind: Kamelet
metadata:
  name: custom-kafka-source
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: kafka-not-secured-source
    properties:
      bootstrapServers: "{{kafka.bootstrap.servers}}"
      topic: "{{kafka.topic}}"

步骤2：在Integration中引用并关联ConfigMap #

apiVersion: camel.apache.org/v1
kind: Integration
metadata:
  name: use-custom-kamelet
spec:
  properties:
    kafka.bootstrap.servers: "{{configmap:my-custom-configmap/kafka.bootstrap.servers}}"
    kafka.topic: "{{configmap:my-custom-configmap/kafka.topic}}"
  flows:
    - from:
        uri: "kamelet:custom-kafka-source"
        steps:
          - to: "log:kafka-messages"

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