templates/bindings/camel-k/caffeine-action-binding.yaml (77 lines of code) (raw):

# example_for_kamelet_doc apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: caffeine-action-binding spec: source: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: timer-source properties: message: '{"foo":"bar"}' period: 10000 steps: - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: json-deserialize-action - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: log-sink - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: insert-header-action properties: name: "caffeine-key" value: "my-key" - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: insert-header-action properties: name: "caffeine-operation" value: "PUT" - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: caffeine-action properties: cacheName: "my-cache" # extract the foo field from the body, cleaning the body - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: extract-field-action properties: field: '{"foo"}' - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: log-sink - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: insert-header-action properties: name: "caffeine-key" value: "my-key" - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: insert-header-action properties: name: "caffeine-operation" value: "GET" # retrieve the json payload from the cache and put into the body - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: caffeine-action properties: cacheName: "my-cache" sink: ref: kind: KafkaTopic apiVersion: kafka.strimzi.io/v1beta1 name: my-topic