Kafka を設定します。

kamelet バインディングを作成します。

kamelet バインディングをリソースとしてプロジェクトに適用します。

Camel K Operator は、kamelet バインディングごとに個別の Camel K インテグレーションを生成します。

任意のエディターで、以下の基本構造で YAML ファイルを作成します。

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

kamelet binding の名前を追加します。この例では、バインディングが coffee-source kamelet を kafka-sink kamelet に接続するため、名前は coffees-to-kafka になります。

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

kamelet バインディングのソースの場合は、データソース kamelet を指定し (たとえば、coffee-source kamelet はコーヒーに関するデータが含まれるイベントを生成します)、kamelet のパラメーターを設定します。

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

kamelet binding のシンクの場合は、kafka-sink kamelets およびその必要なパラメーターを指定します。

たとえば、Kafka クラスターが OpenShift Streams にある場合 (securityProtocol パラメーターを設定する必要はありません)。

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: coffees-to-kafka
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: coffee-source
    properties:
      period: 5000
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: kafka-sink
    properties:
      bootstrapServers: "broker.url:9092""
      password: "testpassword"
      topic: "test-topic"
      user: "testuser"

たとえば、Kafka クラスターが AMQ Streams にある場合は、securityProtocol パラメーターを “PLAINTEXT” に設定する必要があります。

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: coffees-to-kafka
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: coffee-source
    properties:
      period: 5000
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: kafka-sink
    properties:
      bootstrapServers: "broker.url:9092""
      password: "testpassword"
      topic: "test-topic"
      user: "testuser"
      securityProtocol: "PLAINTEXT"

KameletBinding をリソースとして OpenShift namespace に追加します。

oc apply -f <kamelet binding filename>

以下に例を示します。

oc apply -f coffees-to-kafka.yaml

Camel K Operator は、KameletBinding リソースを使用して Camel K インテグレーションを生成し、実行します。ビルドに数分かかる場合があります。

kamelet バインディングリソースのステータスを表示するには、次のコマンドを実行します。

oc get kameletbindings

インテグレーションの状態を表示するには、以下を実行します。

oc get integrations

インテグレーションのログを表示するには、以下を実行します。

kamel logs <integration> -n <project>

以下に例を示します。

kamel logs coffees-to-kafka -n my-camel-k-kafka

結果は以下の出力に似ています。

...
[1] 2021-06-21 07:48:12,696 INFO  [io.quarkus] (main) camel-k-integration 1.4.0 on JVM (powered by Quarkus 1.13.0.Final) started in 2.790s.

任意のエディターで、以下の基本構造で YAML ファイルを作成します。

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

kamelet binding の名前を追加します。この例では、バインディングが kafka-source kamelet を log-sink kamelet に接続するため、名前は kafka-to-log になります。

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

kamelet バインディングのソースの場合は、kafka-source kamelet を指定し、そのパラメーターを設定します。

たとえば、Kafka クラスターが OpenShift Streams にある場合 (securityProtocol パラメーターを設定する必要はありません)。

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: kafka-to-log
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: kafka-source
    properties:
      bootstrapServers: "broker.url:9092"
      password: "testpassword"
      topic: "test-topic"
      user: "testuser"
  sink:

たとえば、Kafka クラスターが AMQ Streams にある場合は、securityProtocol パラメーターを “PLAINTEXT” に設定する必要があります。

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: kafka-to-log
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: kafka-source
    properties:
      bootstrapServers: "broker.url:9092"
      password: "testpassword"
      topic: "test-topic"
      user: "testuser"
      securityProtocol: "PLAINTEXT"
  sink:

kamelet バインディングのシンクでは、データコンシューマー kamelet (例: log-sink kamelet) を指定し、kamelet のパラメーターを設定します。以下に例を示します。

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: kafka-to-log
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: kafka-source
    properties:
      bootstrapServers: "broker.url:9092"
      password: "testpassword"
      topic: "test-topic"
      user: "testuser"
      securityProtocol: "PLAINTEXT" // only for AMQ streams
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: log-sink

kamelet バインディングをリソースとして OpenShift namespace に追加します。

oc apply -f <kamelet binding filename>

以下に例を示します。

oc apply -f kafka-to-log.yaml

Camel K Operator は、KameletBinding リソースを使用して Camel K インテグレーションを生成し、実行します。ビルドに数分かかる場合があります。

kamelet バインディングリソースのステータスを表示するには、次のコマンドを実行します。

oc get kameletbindings

インテグレーションの状態を表示するには、以下を実行します。

oc get integrations

インテグレーションのログを表示するには、以下を実行します。

kamel logs <integration> -n <project>

以下に例を示します。

kamel logs kafka-to-log -n my-camel-k-kafka

この出力では、以下の例のようにコーヒーイベントが表示されるはずです。

2021-07-20 17:15:56,725 INFO  [log-sink-E80C5C904418150-0000000000000001] (Camel (camel-1) thread #0 - timer://tick) {"id":7259,"uid":"a4ecb7c2-05b8-4a49-b0d2-d1e8db5bc5e2","blend_name":"Postmodern Symphony","origin":"Huila, Colombia","variety":"Kona","notes":"delicate, chewy, black currant, red apple, star fruit","intensifier":"balanced"}

実行中のインテグレーションを停止するには、関連付けられた kamelet バインディングリソースを削除します。

oc delete kameletbindings/<kameletbinding-name>

以下に例を示します。

oc delete kameletbindings/kafka-to-log

Knative を設定します。

kamelet バインディングを作成します。

任意のエディターで、以下の基本構造で YAML ファイルを作成します。

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

kamelet binding の名前を追加します。この例では、バインディングが coffee-source kamelet を Knative 宛先に接続するため、名前は coffees-to-knative になります。

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

kamelet バインディングのソースの場合は、データソース kamelet を指定し (たとえば、coffee-source kamelet はコーヒーに関するデータが含まれるイベントを生成します)、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:

kamelet バインディングのシンクでは、Knative チャネルまたはブローカーおよび必要なパラメーターを指定します。

以下の例では、Knative チャネルをシンクとして指定します。

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

この例では、Knative ブローカーをシンクとして指定します。

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

KameletBinding をリソースとして OpenShift namespace に追加します。

oc apply -f <kamelet binding filename>

以下に例を示します。

oc apply -f coffees-to-knative.yaml

Camel K Operator は、KameletBinding リソースを使用して Camel K インテグレーションを生成し、実行します。ビルドに数分かかる場合があります。

KameletBinding のステータスを表示するには、次のコマンドを実行します。

oc get kameletbindings

インテグレーションの状態を表示するには、以下を実行します。

oc get integrations

インテグレーションのログを表示するには、以下を実行します。

kamel logs <integration> -n <project>

以下に例を示します。

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

結果は以下の出力に似ています。

...
[1] 2021-06-21 07:48:12,696 INFO  [io.quarkus] (main) camel-k-integration 1.4.0 on JVM (powered by Quarkus 1.13.0.Final) started in 2.790s.

任意のエディターで、以下の基本構造で YAML ファイルを作成します。

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

kamelet binding の名前を追加します。この例では、バインディングが Knative 宛先を log-sink kamelet に接続するため、名前は knative-to-log になります。

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

kamelet バインディングのソースでは、Knative チャネルまたはブローカーおよび必要なパラメーターを指定します。

以下の例では、Knative チャネルをソースとして指定します。

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:

この例では、Knative ブローカーをソースとして指定します。

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:

kamelet バインディングのシンクでは、データコンシューマー kamelet (例: log-sink kamelet) を指定し、kamelet のパラメーターを設定します。以下に例を示します。

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

KameletBinding をリソースとして OpenShift namespace に追加します (oc apply -f <kamelet binding filename>)。

以下に例を示します。

oc apply -f knative-to-log.yaml

Camel K Operator は、KameletBinding リソースを使用して Camel K インテグレーションを生成し、実行します。ビルドに数分かかる場合があります。

KameletBinding のステータスを表示するには、次のコマンドを実行します。

oc get kameletbindings

インテグレーションの状態を表示するには、以下を実行します。

oc get integrations

インテグレーションのログを表示するには、以下を実行します。

kamel logs <integration> -n <project>

以下に例を示します。

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

この出力では、以下の例のようにコーヒーイベントが表示されるはずです。

[1] 2021-07-23 13:06:38,111 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] 2021-07-23 13:06:43,273 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"}

実行中のインテグレーションを停止するには、関連付けられた kamelet バインディングリソースを削除します。

oc delete kameletbindings/<kameletbinding-name>

以下に例を示します。

oc delete kameletbindings/knative-to-log