此内容没有您所选择的语言版本。

Chapter 24. Insert Header Action

Adds a header with a constant value to the message in transit.

24.1. Configuration Options
复制链接

The following table summarizes the configuration options available for the insert-header-action Kamelet:

Expand

Property	Name	Description	Type	Default	Example
name *	Name	The name of the header to add. For Knative only, the name of the header requires a CloudEvent (`ce-`) prefix.	string
value *	Value	The value of the header	string

Note

Fields marked with an asterisk (*) are mandatory.

24.2. Dependencies
复制链接

At runtime, the insert-header-action Kamelet relies upon the presence of the following dependencies:

camel:core
camel:kamelet

24.3. Usage
复制链接

This section describes how you can use the insert-header-action.

You can use the insert-header-action Kamelet as an intermediate step in a Knative binding. The following example adds the ce-foo header to the data coming from the timer-source Kamelet. The CloudEvents (ce-) prefix for the header name is required.

insert-header-action-binding.yaml

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: insert-header-action-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: timer-source
    properties:
      message: "Hello"
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: insert-header-action
    properties:
      name: "ce-foo"
      value: "The Value"
  sink:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: insert-header-action-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: timer-source
    properties:
      message: "Hello"
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: insert-header-action
    properties:
      name: "ce-foo"
      value: "The Value"
  sink:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel

Copy to Clipboard

Toggle word wrap

24.3.1.1. Prerequisite
复制链接

Make sure you have "Red Hat Integration - Camel K" installed into the OpenShift cluster you’re connected to.

24.3.1.2. Procedure for using the cluster CLI
复制链接

Save the insert-header-action-binding.yaml file to your local drive, and then edit it as needed for your configuration.
Run the action by using the following command:
```
oc apply -f insert-header-action-binding.yaml
```
```
oc apply -f insert-header-action-binding.yaml
```
Copy to Clipboard Toggle word wrap

24.3.1.3. Procedure for using the Kamel CLI
复制链接

Configure and run the action by using the following command:

kamel bind timer-source?message=Hello --step insert-header-action -p "step-0.name=ce-foo" -p "step-0.value=The Value" channel:mychannel

kamel bind timer-source?message=Hello --step insert-header-action -p "step-0.name=ce-foo" -p "step-0.value=The Value" channel:mychannel

Copy to Clipboard

Toggle word wrap

This command creates the KameletBinding in the current namespace on the cluster.

24.3.2. Kafka Action
复制链接

You can use the insert-header-action Kamelet as an intermediate step in a Kafka binding. The following example adds the foo header to the data coming from the timer-source Kamelet.

insert-header-action-binding.yaml

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: timer-to-kafka
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: timer-source
    properties:
      period: "10000"
      message: 'msg'
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: insert-header-action
    properties:
      name: "foo"
      value: "The Value"
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: kafka-sink
    properties:
      bootstrapServers: "my-cluster-kafka-bootstrap.myproject.svc:9092"
      password: "XXX"
      topic: "my-topic"
      user: "XXX"
      securityProtocol: "PLAINTEXT"

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: timer-to-kafka
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: timer-source
    properties:
      period: "10000"
      message: 'msg'
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: insert-header-action
    properties:
      name: "foo"
      value: "The Value"
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: kafka-sink
    properties:
      bootstrapServers: "my-cluster-kafka-bootstrap.myproject.svc:9092"
      password: "XXX"
      topic: "my-topic"
      user: "XXX"
      securityProtocol: "PLAINTEXT"

Copy to Clipboard

Toggle word wrap

24.3.2.1. Prerequisites
复制链接

Ensure that you’ve installed the AMQ Streams operator in your OpenShift cluster and created a topic named my-topic in the current namespace.
Make sure that you have "Red Hat Integration - Camel K" installed on the OpenShift cluster that you’re connected to.

24.3.2.2. Procedure for using the cluster CLI
复制链接

Save the insert-header-action-binding.yaml file to your local drive, and then edit it as needed for your configuration.
Run the action by using the following command:
```
oc apply -f insert-header-action-binding.yaml
```
```
oc apply -f insert-header-action-binding.yaml
```
Copy to Clipboard Toggle word wrap

24.3.2.3. Procedure for using the Kamel CLI
复制链接

Configure and run the action by using the following command:

kamel bind timer-source?message=Hello --step insert-header-action -p "step-0.name=foo" -p "step-0.value=The Value" kafka.strimzi.io/v1beta1:KafkaTopic:my-topic

kamel bind timer-source?message=Hello --step insert-header-action -p "step-0.name=foo" -p "step-0.value=The Value" kafka.strimzi.io/v1beta1:KafkaTopic:my-topic

Copy to Clipboard

Toggle word wrap

This command creates the KameletBinding in the current namespace on the cluster.

24.4. Kamelet source file
复制链接

https://github.com/openshift-integration/kamelet-catalog/blob/kamelet-catalog-1.6/insert-header-action.kamelet.yaml

返回顶部

此内容没有您所选择的语言版本。

Chapter 24. Insert Header Action

24.1. Configuration Options
复制链接

24.2. Dependencies
复制链接

24.3. Usage
复制链接

24.3.1. Knative Action
复制链接

24.3.1.1. Prerequisite
复制链接

24.3.1.2. Procedure for using the cluster CLI
复制链接

24.3.1.3. Procedure for using the Kamel CLI
复制链接

24.3.2. Kafka Action
复制链接

24.3.2.1. Prerequisites
复制链接

24.3.2.2. Procedure for using the cluster CLI
复制链接

24.3.2.3. Procedure for using the Kamel CLI
复制链接

24.4. Kamelet source file
复制链接

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

此内容没有您所选择的语言版本。

Chapter 24. Insert Header Action

24.1. Configuration Options复制链接链接已复制到粘贴板!

24.2. Dependencies复制链接链接已复制到粘贴板!

24.3. Usage复制链接链接已复制到粘贴板!

24.3.1. Knative Action复制链接链接已复制到粘贴板!

24.3.1.1. Prerequisite复制链接链接已复制到粘贴板!

24.3.1.2. Procedure for using the cluster CLI复制链接链接已复制到粘贴板!

24.3.1.3. Procedure for using the Kamel CLI复制链接链接已复制到粘贴板!

24.3.2. Kafka Action复制链接链接已复制到粘贴板!

24.3.2.1. Prerequisites复制链接链接已复制到粘贴板!

24.3.2.2. Procedure for using the cluster CLI复制链接链接已复制到粘贴板!

24.3.2.3. Procedure for using the Kamel CLI复制链接链接已复制到粘贴板!

24.4. Kamelet source file复制链接链接已复制到粘贴板!

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

24.1. Configuration Options
复制链接

24.2. Dependencies
复制链接

24.3. Usage
复制链接

24.3.1. Knative Action
复制链接

24.3.1.1. Prerequisite
复制链接

24.3.1.2. Procedure for using the cluster CLI
复制链接

24.3.1.3. Procedure for using the Kamel CLI
复制链接

24.3.2. Kafka Action
复制链接

24.3.2.1. Prerequisites
复制链接

24.3.2.2. Procedure for using the cluster CLI
复制链接

24.3.2.3. Procedure for using the Kamel CLI
复制链接

24.4. Kamelet source file
复制链接