Подстановка даты и времени в Apache — файл Camel Kubernetes Yaml

Я хотел развернуть коннектор приемника S3 kafka (используя Apache Camel) в kubernetes, используя справочный документ https://ibm-cloud-architecture.github.io/refarch-eda/scenarios/connect-s3/

Заполнитель DateTime (${date:now:yyyyMMdd-HHmmssSSS}, используемый в этом файле развертывания Kubernetes, не разрешен. В то время как ${file:} разрешен.

apiVersion: kafka.strimzi.io/v1alpha1
kind: KafkaConnector
metadata:
  name: s3-sink-connector
  labels:
    strimzi.io/cluster: my-connect-cluster
spec:
  class: org.apache.camel.kafkaconnector.CamelSinkConnector
  tasksMax: 1
  config:
    key.converter: org.apache.kafka.connect.storage.StringConverter
    value.converter: org.apache.kafka.connect.storage.StringConverter
    topics: my-replicated-topic
    camel.sink.url: aws-s3://kafka-s3?keyName=s3-connect/${date:now:yyyyMMdd-HHmmssSSS} <-- NOT RESOLVED
    camel.component.aws-s3.configuration.autocloseBody: false
    camel.component.aws-s3.accessKey: ${file:/opt/kafka/external-configuration/aws-credentials/aws-credentials.properties:aws_access_key_id}  <-- RESOLVED
    camel.component.aws-s3.secretKey: ${file:/opt/kafka/external-configuration/aws-credentials/aws-credentials.properties:aws_secret_access_key}  <-- RESOLVED

В этом документе я вижу и ${date:now:yyyyMMdd}, и exchangeId (https://camel.apache.org/components/latest/languages/simple-language.html)


person saranya elumalai    schedule 29.05.2020    source источник


Ответы (1)


Как описано в этом выпуске: https://github.com/apache/camel-kafka-connector/issues/251 DateTime placeholders пока не поддерживаются.

Вероятно, они будут соответствовать https://github.com/apache/camel-kafka-connector/issues/252.

person Valdar    schedule 31.05.2020
comment
Да, я создал билет github.com/apache/camel-kafka- коннектор/проблемы/251. Рад, что над ним работают! - person saranya elumalai; 04.06.2020