Chapter 3. Connecting to Knative with Kamelets

Set up Knative:

Create Kamelet Bindings:

In an editor of your choice, create a YAML file with the following basic structure:

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name:
spec:
  source:
  sink:

Add a name for the Kamelet Binding. For this example, the name is coffees-to-knative because the binding connects the coffee-source Kamelet to a Knative destination.

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: coffees-to-knative
spec:
  source:
  sink:

For the Kamelet Binding’s source, specify a data source Kamelet (for example, the coffee-source Kamelet produces events that contain data about coffee) and configure any parameters for the Kamelet.

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: coffees-to-knative
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: coffee-source
    properties:
      period: 5000
  sink:

For the Kamelet Binding’s sink specify the Knative channel or broker and the required parameters.

This example specifies a Knative channel as the sink:

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: coffees-to-knative
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: coffee-source
    properties:
      period: 5000
  sink:
    ref:
      apiVersion: messaging.knative.dev/v1
      kind: InMemoryChannel
      name: mychannel

This example specifies a Knative broker as the sink:

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: coffees-to-knative
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: coffee-source
    properties:
      period: 5000
  sink:
      ref:
        kind: Broker
        apiVersion: eventing.knative.dev/v1
        name: default
      properties:
        type: coffee

Add the Kamelet Binding as a resource to your OpenShift namespace:

oc apply -f <kamelet binding filename>

For example:

oc apply -f coffees-to-knative.yaml

The Camel K operator generates and runs a Camel K integration by using the KameletBinding resource. It might take a few minutes to build.

To see the status of the KameletBinding:

oc get kameletbindings

To see the status of their integrations:

oc get integrations

To view the integration’s log:

kamel logs <integration> -n <project>

For example:

kamel logs coffees-to-knative -n my-camel-knative

In an editor of your choice, create a YAML file with the following basic structure:

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name:
spec:
  source:
  sink:

Add a name for the Kamelet Binding. For this example, the name is knative-to-log because the binding connects the Knative destination to the log-sink Kamelet.

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: knative-to-log
spec:
  source:
  sink:

For the Kamelet Binding’s source, specify the Knative channel or broker and the required parameters.

This example specifies a Knative channel as the source:

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: knative-to-log
spec:
  source:
    ref:
      apiVersion: messaging.knative.dev/v1
      kind: InMemoryChannel
      name: mychannel
  sink:

This example specifies a Knative broker as the source:

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: knative-to-log
spec:
  source:
    ref:
      kind: Broker
      apiVersion: eventing.knative.dev/v1
      name: default
    properties:
      type: coffee
sink:

For the Kamelet Binding’s sink, specify the data consumer Kamelet (for example, the log-sink Kamelet) and configure any parameters for the Kamelet, for example:

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: knative-to-log
spec:
  source:
    ref:
      apiVersion: messaging.knative.dev/v1
      kind: InMemoryChannel
      name: mychannel
  sink:
    ref:
      apiVersion: camel.apache.org/v1alpha1
      kind: Kamelet
      name: log-sink
    properties:
      showStreams: true

Add the Kamelet Binding as a resource to your OpenShift namespace: oc apply -f <kamelet binding filename>

For example:

oc apply -f knative-to-log.yaml

The Camel K operator generates and runs a Camel K integration by using the KameletBinding resource. It might take a few minutes to build.

To see the status of the KameletBinding:

oc get kameletbindings

To see the status of the integration:

oc get integrations

To view the integration’s log:

kamel logs <integration> -n <project>

For example:

kamel logs knative-to-log -n my-camel-knative

In the output, you should see coffee events, for example:

[1] INFO [sink] (vert.x-worker-thread-1) {"id":254,"uid":"8e180ef7-8924-4fc7-ab81-d6058618cc42","blend_name":"Good-morning Star","origin":"Santander, Colombia","variety":"Kaffa","notes":"delicate, creamy, lemongrass, granola, soil","intensifier":"sharp"}
[1] INFO [sink] (vert.x-worker-thread-2) {"id":8169,"uid":"3733c3a5-4ad9-43a3-9acc-d4cd43de6f3d","blend_name":"Caf? Java","origin":"Nayarit, Mexico","variety":"Red Bourbon","notes":"unbalanced, full, granola, bittersweet chocolate, nougat","intensifier":"delicate"}

To stop a running integration, delete the associated Kamelet Binding resource:

oc delete kameletbindings/<kameletbinding-name>

For example:

oc delete kameletbindings/knative-to-log