kamelets/kafka-to-log-with-value-to-key/flow-binding.yaml (33 lines of code) (raw):

apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: kafka-to-log-with-value-to-key spec: source: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: kafka-not-secured-source properties: bootstrapServers: 'my-cluster-kafka-bootstrap:9092' topic: 'test-topic' steps: - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: json-deserialize-action - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: value-to-key-action properties: fields: "foo,bar" - ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: json-serialize-action sink: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: log-sink