Este conteúdo não está disponível no idioma selecionado.

Chapter 3. Avro Serialize Action

Serialize payload to Avro

3.1. Configuration Options
Copiar o link

The following table summarizes the configuration options available for the avro-serialize-action Kamelet:

Expand

Property	Name	Description	Type	Default	Example
schema *	Schema	The Avro schema to use during serialization (as single-line, using JSON format)	string		`"{\"type\": \"record\", \"namespace\": \"com.example\", \"name\": \"FullName\", \"fields\": [{\"name\": \"first\", \"type\": \"string\"},{\"name\": \"last\", \"type\": \"string\"}]}"`
validate	Validate	Indicates if the content must be validated against the schema	boolean	`true`

Note

Fields marked with an asterisk (*) are mandatory.

3.2. Dependencies
Copiar o link

At runtime, the avro-serialize-action Kamelet relies upon the presence of the following dependencies:

github:openshift-integration.kamelet-catalog:camel-kamelets-utils:kamelet-catalog-1.6-SNAPSHOT
camel:kamelet
camel:core
camel:jackson-avro

3.3. Usage
Copiar o link

This section describes how you can use the avro-serialize-action.

3.3.1. Knative Action
Copiar o link

You can use the avro-serialize-action Kamelet as an intermediate step in a Knative binding.

avro-serialize-action-binding.yaml

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: avro-serialize-action-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: timer-source
    properties:
      message: '{"first":"Ada","last":"Lovelace"}'
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: json-deserialize-action
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: avro-serialize-action
    properties:
      schema: "{\"type\": \"record\", \"namespace\": \"com.example\", \"name\": \"FullName\", \"fields\": [{\"name\": \"first\", \"type\": \"string\"},{\"name\": \"last\", \"type\": \"string\"}]}"
  sink:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: avro-serialize-action-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: timer-source
    properties:
      message: '{"first":"Ada","last":"Lovelace"}'
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: json-deserialize-action
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: avro-serialize-action
    properties:
      schema: "{\"type\": \"record\", \"namespace\": \"com.example\", \"name\": \"FullName\", \"fields\": [{\"name\": \"first\", \"type\": \"string\"},{\"name\": \"last\", \"type\": \"string\"}]}"
  sink:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel

Copy to Clipboard

Toggle word wrap

3.3.1.1. Prerequisite
Copiar o link

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

3.3.1.2. Procedure for using the cluster CLI
Copiar o link

Save the avro-serialize-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 avro-serialize-action-binding.yaml
```
```
oc apply -f avro-serialize-action-binding.yaml
```
Copy to Clipboard Toggle word wrap

3.3.1.3. Procedure for using the Kamel CLI
Copiar o link

Configure and run the action by using the following command:

kamel bind --name avro-serialize-action-binding timer-source?message='{"first":"Ada","last":"Lovelace"}' --step json-deserialize-action --step avro-serialize-action -p step-1.schema='{"type": "record", "namespace": "com.example", "name": "FullName", "fields": [{"name": "first", "type": "string"},{"name": "last", "type": "string"}]}' channel:mychannel

kamel bind --name avro-serialize-action-binding timer-source?message='{"first":"Ada","last":"Lovelace"}' --step json-deserialize-action --step avro-serialize-action -p step-1.schema='{"type": "record", "namespace": "com.example", "name": "FullName", "fields": [{"name": "first", "type": "string"},{"name": "last", "type": "string"}]}' channel:mychannel

Copy to Clipboard

Toggle word wrap

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

3.3.2. Kafka Action
Copiar o link

You can use the avro-serialize-action Kamelet as an intermediate step in a Kafka binding.

avro-serialize-action-binding.yaml

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: avro-serialize-action-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: timer-source
    properties:
      message: '{"first":"Ada","last":"Lovelace"}'
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: json-deserialize-action
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: avro-serialize-action
    properties:
      schema: "{\"type\": \"record\", \"namespace\": \"com.example\", \"name\": \"FullName\", \"fields\": [{\"name\": \"first\", \"type\": \"string\"},{\"name\": \"last\", \"type\": \"string\"}]}"
  sink:
    ref:
      kind: KafkaTopic
      apiVersion: kafka.strimzi.io/v1beta1
      name: my-topic

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: avro-serialize-action-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: timer-source
    properties:
      message: '{"first":"Ada","last":"Lovelace"}'
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: json-deserialize-action
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: avro-serialize-action
    properties:
      schema: "{\"type\": \"record\", \"namespace\": \"com.example\", \"name\": \"FullName\", \"fields\": [{\"name\": \"first\", \"type\": \"string\"},{\"name\": \"last\", \"type\": \"string\"}]}"
  sink:
    ref:
      kind: KafkaTopic
      apiVersion: kafka.strimzi.io/v1beta1
      name: my-topic

Copy to Clipboard

Toggle word wrap

3.3.2.1. Prerequisites
Copiar o link

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 also sure you have "Red Hat Integration - Camel K" installed into the OpenShift cluster you’re connected to.

3.3.2.2. Procedure for using the cluster CLI
Copiar o link

Save the avro-serialize-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 avro-serialize-action-binding.yaml
```
```
oc apply -f avro-serialize-action-binding.yaml
```
Copy to Clipboard Toggle word wrap

3.3.2.3. Procedure for using the Kamel CLI
Copiar o link

Configure and run the action by using the following command:

kamel bind --name avro-serialize-action-binding timer-source?message='{"first":"Ada","last":"Lovelace"}' --step json-deserialize-action --step avro-serialize-action -p step-1.schema='{"type": "record", "namespace": "com.example", "name": "FullName", "fields": [{"name": "first", "type": "string"},{"name": "last", "type": "string"}]}' kafka.strimzi.io/v1beta1:KafkaTopic:my-topic

kamel bind --name avro-serialize-action-binding timer-source?message='{"first":"Ada","last":"Lovelace"}' --step json-deserialize-action --step avro-serialize-action -p step-1.schema='{"type": "record", "namespace": "com.example", "name": "FullName", "fields": [{"name": "first", "type": "string"},{"name": "last", "type": "string"}]}' 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.

3.4. Kamelet source file
Copiar o link

https://github.com/openshift-integration/kamelet-catalog/tree/kamelet-catalog-1.8//avro-serialize-action.kamelet.yaml

Voltar ao topo

Este conteúdo não está disponível no idioma selecionado.

Chapter 3. Avro Serialize Action

3.1. Configuration Options
Copiar o link

3.2. Dependencies
Copiar o link

3.3. Usage
Copiar o link

3.3.1. Knative Action
Copiar o link

3.3.1.1. Prerequisite
Copiar o link

3.3.1.2. Procedure for using the cluster CLI
Copiar o link

3.3.1.3. Procedure for using the Kamel CLI
Copiar o link

3.3.2. Kafka Action
Copiar o link

3.3.2.1. Prerequisites
Copiar o link

3.3.2.2. Procedure for using the cluster CLI
Copiar o link

3.3.2.3. Procedure for using the Kamel CLI
Copiar o link

3.4. Kamelet source file
Copiar o link

Aprender

Experimente, compre e venda

Comunidades

Sobre a documentação da Red Hat

Tornando o open source mais inclusivo

Sobre a Red Hat

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

Este conteúdo não está disponível no idioma selecionado.

Chapter 3. Avro Serialize Action

3.1. Configuration OptionsCopiar o linkLink copiado para a área de transferência!

3.2. DependenciesCopiar o linkLink copiado para a área de transferência!

3.3. UsageCopiar o linkLink copiado para a área de transferência!

3.3.1. Knative ActionCopiar o linkLink copiado para a área de transferência!

3.3.1.1. PrerequisiteCopiar o linkLink copiado para a área de transferência!

3.3.1.2. Procedure for using the cluster CLICopiar o linkLink copiado para a área de transferência!

3.3.1.3. Procedure for using the Kamel CLICopiar o linkLink copiado para a área de transferência!

3.3.2. Kafka ActionCopiar o linkLink copiado para a área de transferência!

3.3.2.1. PrerequisitesCopiar o linkLink copiado para a área de transferência!

3.3.2.2. Procedure for using the cluster CLICopiar o linkLink copiado para a área de transferência!

3.3.2.3. Procedure for using the Kamel CLICopiar o linkLink copiado para a área de transferência!

3.4. Kamelet source fileCopiar o linkLink copiado para a área de transferência!

Aprender

Experimente, compre e venda

Comunidades

Sobre a documentação da Red Hat

Tornando o open source mais inclusivo

Sobre a Red Hat

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

3.1. Configuration Options
Copiar o link

3.2. Dependencies
Copiar o link

3.3. Usage
Copiar o link

3.3.1. Knative Action
Copiar o link

3.3.1.1. Prerequisite
Copiar o link

3.3.1.2. Procedure for using the cluster CLI
Copiar o link

3.3.1.3. Procedure for using the Kamel CLI
Copiar o link

3.3.2. Kafka Action
Copiar o link

3.3.2.1. Prerequisites
Copiar o link

3.3.2.2. Procedure for using the cluster CLI
Copiar o link

3.3.2.3. Procedure for using the Kamel CLI
Copiar o link

3.4. Kamelet source file
Copiar o link