5.6. チャネル

5.6.1. チャネルおよびサブスクリプション
リンクのコピー

チャネルは、単一のイベント転送および永続レイヤーを定義するカスタムリソースです。イベントがイベントソースまたは生成側からチャネルに送信された後に、これらのイベントはサブスクリプションを使用して複数の Knative サービスまたは他のシンクに送信できます。

サポートされている Channel オブジェクトをインスタンス化することでチャネルを作成し、Subscription オブジェクトの delivery 仕様を変更して再配信の試行を設定できます。

Channel オブジェクトが作成されると、変更用の受付 Webhook はデフォルトのチャネル実装に基づいて Channel オブジェクトの spec.channelTemplate プロパティーのセットを追加します。たとえば、InMemoryChannel のデフォルト実装の場合、Channel オブジェクトは以下のようになります。

apiVersion: messaging.knative.dev/v1
kind: Channel
metadata:
  name: example-channel
  namespace: default
spec:
  channelTemplate:
    apiVersion: messaging.knative.dev/v1
    kind: InMemoryChannel

チャネルコントローラーは、その後に spec.channelTemplate 設定に基づいてサポートするチャネルインスタンスを作成します。

注記

spec.channelTemplate プロパティーは作成後に変更できません。それらは、ユーザーではなくデフォルトのチャネルメカニズムで設定されるためです。

このメカニズムが上記の例で使用される場合、汎用バッキングチャネルおよび InMemoryChannel チャネルなど 2 つのオブジェクトが作成されます。別のデフォルトチャネルの実装を使用している場合、InMemoryChannel は実装に固有のものに置き換えられます。たとえば、Knative Kafka の場合、KafkaChannel チャネルが作成されます。

バッキングチャネルは、サブスクリプションをユーザー作成のチャネルオブジェクトにコピーし、ユーザー作成チャネルオブジェクトのステータスを、バッキングチャネルのステータスを反映するように設定します。

5.6.1.1. チャネルの実装タイプ
リンクのコピー

InMemoryChannel および KafkaChannel チャネルの実装は、開発目的で OpenShift Serverless で使用できます。

以下は、InMemoryChannel タイプのチャネルの制限です。

イベントの永続性は利用できません。Pod がダウンすると、その Pod のイベントが失われます。
InMemoryChannel チャネルはイベントの順序を実装しないため、チャネルで同時に受信される 2 つのイベントはいずれの順序でもサブスクライバーに配信できます。
サブスクライバーがイベントを拒否する場合、再配信はデフォルトで試行されません。Subscription オブジェクトの delivery 仕様を変更することで、再配信の試行を設定できます。

5.6.2. チャネルの作成
リンクのコピー

5.6.2.1. Administrator パースペクティブを使用したチャネルの作成
リンクのコピー

Knative Eventing をクラスターにインストールしたら、管理者パースペクティブを使用してチャネルを作成できます。

前提条件

OpenShift Serverless Operator および Knative Eventing が OpenShift Container Platform クラスターにインストールされている。
Web コンソールにログインしており、Administrator パースペクティブを使用している。
OpenShift Container Platform のクラスター管理者パーミッションがある。

手順

OpenShift Container Platform Web コンソールの Administrator パースペクティブで、 Serverless Eventing に移動します。
Create 一覧で、Channel を選択します。Channel ページに移動します。
タイプ リストで、作成する Channel オブジェクトのタイプを選択します。
注記
現時点で、InMemoryChannel チャネルオブジェクトのみがデフォルトでサポートされます。OpenShift Serverless に Knative Kafka をインストールしている場合は、Kafka チャネルを利用できます。
Create をクリックします。

5.6.2.2. Developer パースペクティブを使用したチャネルの作成
リンクのコピー

OpenShift Container Platform Web コンソールを使用すると、チャネルを作成するための合理的で直感的なユーザーインターフェイスが提供されます。Knative Eventing がクラスターにインストールされると、Web コンソールを使用してチャネルを作成できます。

前提条件

OpenShift Container Platform Web コンソールにログインしている。
OpenShift Serverless Operator および Knative Eventing が OpenShift Container Platform クラスターにインストールされている。
OpenShift Container Platform でアプリケーションおよび他のワークロードを作成するために、プロジェクトを作成しているか、適切なロールおよびパーミッションを持つプロジェクトにアクセスできる。

手順

Developer パースペクティブで、+Add Channel に移動します。
タイプ リストで、作成する Channel オブジェクトのタイプを選択します。
Create をクリックします。

検証

Topology ページに移動して、チャネルが存在することを確認します。

5.6.2.3. Knative CLI を使用したチャネルの作成
リンクのコピー

チャネルを作成するために Knative (kn) CLI を使用すると、YAML ファイルを直接修正するよりも合理的で直感的なユーザーインターフェイスが得られます。kn channel create コマンドを使用してチャネルを作成できます。

前提条件

OpenShift Serverless Operator および Knative Eventing がクラスターにインストールされている。
Knative (kn) CLI をインストールしている。
OpenShift Container Platform でアプリケーションおよび他のワークロードを作成するために、プロジェクトを作成しているか、適切なロールおよびパーミッションを持つプロジェクトにアクセスできる。

手順

チャネルを作成します。
```
$ kn channel create <channel_name> --type <channel_type>
```
チャネルタイプはオプションですが、指定する場合、Group:Version:Kind の形式で指定する必要があります。たとえば、InMemoryChannel オブジェクトを作成できます。
```
$ kn channel create mychannel --type messaging.knative.dev:v1:InMemoryChannel
```
出力例
```
Channel 'mychannel' created in namespace 'default'.
```

検証

チャネルが存在することを確認するには、既存のチャネルを一覧表示し、出力を検査します。

$ kn channel list

出力例

kn channel list
NAME        TYPE              URL                                                     AGE   READY   REASON
mychannel   InMemoryChannel   http://mychannel-kn-channel.default.svc.cluster.local   93s   True

チャネルの削除

チャネルを削除します。
```
$ kn channel delete <channel_name>
```

5.6.2.4. YAML を使用したデフォルト実装チャネルの作成
リンクのコピー

YAML ファイルを使用して Knative リソースを作成する場合、宣言的 API を使用するため、再現性の高い方法でチャネルを宣言的に記述することができます。YAML を使用してサーバーレスチャネルを作成するには、Channel オブジェクトを定義する YAML ファイルを作成し、oc apply コマンドを使用してそれを適用する必要があります。

前提条件

OpenShift Serverless Operator および Knative Eventing がクラスターにインストールされている。
OpenShift CLI (oc) をインストールしている。
OpenShift Container Platform でアプリケーションおよび他のワークロードを作成するために、プロジェクトを作成しているか、適切なロールおよびパーミッションを持つプロジェクトにアクセスできる。

手順

Channel オブジェクトを YAML ファイルとして作成します。

apiVersion: messaging.knative.dev/v1
kind: Channel
metadata:
  name: example-channel
  namespace: default

YAML ファイルを適用します。
```
$ oc apply -f <filename>
```

5.6.2.5. YAML を使用した Kafka チャネルの作成
リンクのコピー

YAML ファイルを使用して Knative リソースを作成する場合、宣言的 API を使用するため、再現性の高い方法でチャネルを宣言的に記述することができます。Kafka チャネルを作成することで、Kafka トピックに裏打ちされた Knative Eventing チャネルを作成できます。YAML を使用して Kafka チャネルを作成するには、KafkaChannel オブジェクトを定義する YAML ファイルを作成し、oc apply コマンドを使用してそれを適用する必要があります。

前提条件

OpenShift Serverless Operator、Knative Eventing、および KnativeKafka カスタムリソースは OpenShift Container Platform クラスターにインストールされます。
OpenShift CLI (oc) をインストールしている。
OpenShift Container Platform でアプリケーションおよび他のワークロードを作成するために、プロジェクトを作成しているか、適切なロールおよびパーミッションを持つプロジェクトにアクセスできる。

手順

KafkaChannel オブジェクトを YAML ファイルとして作成します。
```
apiVersion: messaging.knative.dev/v1beta1
kind: KafkaChannel
metadata:
  name: example-channel
  namespace: default
spec:
  numPartitions: 3
  replicationFactor: 1
```
重要
OpenShift Serverless 上の KafkaChannel オブジェクトの API の v1beta1 バージョンのみがサポートされます。非推奨となった v1alpha1 バージョンの API は使用しないでください。
KafkaChannel YAML ファイルを適用します。
```
$ oc apply -f <filename>
```

5.6.2.6. 次のステップ
リンクのコピー

チャネルの作成後に、イベントシンクがチャネルにサブスクライブしてイベントを受信できるように、サブスクリプションを作成します。
イベントがイベントシンクに配信されなかった場合に適用されるイベント配信パラメーターを設定します。イベント配信パラメーターの設定例を参照してください。

5.6.3. デフォルトのチャネル実装
リンクのコピー

default-ch-webhook 設定マップを使用して、Knative Eventing のデフォルトのチャネル実装を指定できます。クラスター全体または 1 つ以上の namespace に対して、デフォルトのチャネルの実装を指定できます。現在、InMemoryChannel および KafkaChannel チャネルタイプがサポートされています。

5.6.3.1. デフォルトチャネル実装の設定
リンクのコピー

前提条件

OpenShift Container Platform に対する管理者権限を持っている。
OpenShift Serverless Operator および Knative Eventing がクラスターにインストールされていること。
デフォルトのチャネル実装として Kafka チャネルを使用する場合は、クラスターに KnativeKafka CR もインストールする必要があります。

手順

KnativeEventing カスタムリソースを変更して、default-ch-webhook 設定マップの設定の詳細を追加します。

apiVersion: operator.knative.dev/v1beta1
kind: KnativeEventing
metadata:
  name: knative-eventing
  namespace: knative-eventing
spec:
  config:


    default-ch-webhook:


      default-ch-config: |
        clusterDefault:


          apiVersion: messaging.knative.dev/v1
          kind: InMemoryChannel
          spec:
            delivery:
              backoffDelay: PT0.5S
              backoffPolicy: exponential
              retry: 5
        namespaceDefaults:


          my-namespace:
            apiVersion: messaging.knative.dev/v1beta1
            kind: KafkaChannel
            spec:
              numPartitions: 1
              replicationFactor: 1

1: spec.config で、変更した設定を追加する設定マップを指定できます。
2: default-ch-webhook 設定マップは、クラスターまたは 1 つ以上の namespace のデフォルトチャネルの実装を指定するために使用できます。
3: クラスター全体のデフォルトのチャネルタイプの設定。この例では、クラスターのデフォルトのチャネル実装は InMemoryChannel です。
4: namespace スコープのデフォルトのチャネルタイプの設定。この例では、my-namespace namespace のデフォルトのチャネル実装は KafkaChannel です。

重要

namespace 固有のデフォルトを設定すると、クラスター全体の設定が上書きされます。

5.6.4. Knative Kafka チャネルのセキュリティー設定
リンクのコピー

5.6.4.1. Kafka チャネルの TLS 認証の設定
リンクのコピー

Transport Layer Security (TLS) は、Apache Kafka クライアントおよびサーバーによって、Knative と Kafka 間のトラフィックを暗号化するため、および認証のために使用されます。TLS は、Knative Kafka のトラフィック暗号化でサポートされている唯一の方法です。

前提条件

OpenShift Container Platform でクラスターまたは専用の管理者パーミッションを持っている。
OpenShift Serverless Operator、Knative Eventing、および KnativeKafka CR は、OpenShift Container Platform クラスターにインストールされている。
OpenShift Container Platform でアプリケーションおよび他のワークロードを作成するために、プロジェクトを作成しているか、適切なロールおよびパーミッションを持つプロジェクトにアクセスできる。
.pem ファイルとして Kafka クラスター CA 証明書が保存されている。
Kafka クラスタークライアント証明書とキーが .pem ファイルとして保存されている。
OpenShift CLI (oc) をインストールしている。

手順

選択された namespace にシークレットとして証明書ファイルを作成します。
```
$ oc create secret -n <namespace> generic <kafka_auth_secret> \
  --from-file=ca.crt=caroot.pem \
  --from-file=user.crt=certificate.pem \
  --from-file=user.key=key.pem
```
重要
キー名に ca.crt、 user.crt、および user.key を使用します。これらの値は変更しないでください。
KnativeKafka カスタムリソースの編集を開始します。
```
$ oc edit knativekafka
```

シークレットおよびシークレットの namespace を参照します。

apiVersion: operator.serverless.openshift.io/v1alpha1
kind: KnativeKafka
metadata:
  namespace: knative-eventing
  name: knative-kafka
spec:
  channel:
    authSecretName: <kafka_auth_secret>
    authSecretNamespace: <kafka_auth_secret_namespace>
    bootstrapServers: <bootstrap_servers>
    enabled: true
  source:
    enabled: true

注記

ブートストラップサーバーで一致するポートを指定するようにしてください。

以下に例を示します。

apiVersion: operator.serverless.openshift.io/v1alpha1
kind: KnativeKafka
metadata:
  namespace: knative-eventing
  name: knative-kafka
spec:
  channel:
    authSecretName: tls-user
    authSecretNamespace: kafka
    bootstrapServers: eventing-kafka-bootstrap.kafka.svc:9094
    enabled: true
  source:
    enabled: true

5.6.4.2. Kafka チャネルの SASL 認証の設定
リンクのコピー

Simple Authentication and Security Layer (SASL) は、Apache Kafka が認証に使用します。クラスターで SASL 認証を使用する場合、ユーザーは Kafka クラスターと通信するために Knative に認証情報を提供する必要があります。そうしないと、イベントを生成または消費できません。

前提条件

OpenShift Container Platform でクラスターまたは専用の管理者パーミッションを持っている。
OpenShift Serverless Operator、Knative Eventing、および KnativeKafka CR は、OpenShift Container Platform クラスターにインストールされている。
OpenShift Container Platform でアプリケーションおよび他のワークロードを作成するために、プロジェクトを作成しているか、適切なロールおよびパーミッションを持つプロジェクトにアクセスできる。
Kafka クラスターのユーザー名およびパスワードがある。
使用する SASL メカニズムを選択している (例: PLAIN、SCRAM-SHA-256、または SCRAM-SHA-512)。
TLS が有効にされている場合、Kafka クラスターの ca.crt 証明書ファイルも必要になります。
OpenShift CLI (oc) をインストールしている。

手順

選択された namespace にシークレットとして証明書ファイルを作成します。

$ oc create secret -n <namespace> generic <kafka_auth_secret> \
  --from-file=ca.crt=caroot.pem \
  --from-literal=password="SecretPassword" \
  --from-literal=saslType="SCRAM-SHA-512" \
  --from-literal=user="my-sasl-user"

キー名に ca.crt、 password、および sasl.mechanism を使用します。これらの値は変更しないでください。

パブリック CA 証明書で SASL を使用する場合は、シークレットの作成時に ca.crt 引数ではなく tls.enabled=true フラグを使用する必要があります。以下に例を示します。

$ oc create secret -n <namespace> generic <kafka_auth_secret> \
  --from-literal=tls.enabled=true \
  --from-literal=password="SecretPassword" \
  --from-literal=saslType="SCRAM-SHA-512" \
  --from-literal=user="my-sasl-user"

KnativeKafka カスタムリソースの編集を開始します。
```
$ oc edit knativekafka
```

シークレットおよびシークレットの namespace を参照します。

apiVersion: operator.serverless.openshift.io/v1alpha1
kind: KnativeKafka
metadata:
  namespace: knative-eventing
  name: knative-kafka
spec:
  channel:
    authSecretName: <kafka_auth_secret>
    authSecretNamespace: <kafka_auth_secret_namespace>
    bootstrapServers: <bootstrap_servers>
    enabled: true
  source:
    enabled: true

注記

ブートストラップサーバーで一致するポートを指定するようにしてください。

以下に例を示します。

apiVersion: operator.serverless.openshift.io/v1alpha1
kind: KnativeKafka
metadata:
  namespace: knative-eventing
  name: knative-kafka
spec:
  channel:
    authSecretName: scram-user
    authSecretNamespace: kafka
    bootstrapServers: eventing-kafka-bootstrap.kafka.svc:9093
    enabled: true
  source:
    enabled: true

5.6. チャネル

5.6.1. チャネルおよびサブスクリプション
リンクのコピー

5.6.1.1. チャネルの実装タイプ
リンクのコピー

5.6.2. チャネルの作成
リンクのコピー

5.6.2.1. Administrator パースペクティブを使用したチャネルの作成
リンクのコピー

5.6.2.2. Developer パースペクティブを使用したチャネルの作成
リンクのコピー

5.6.2.3. Knative CLI を使用したチャネルの作成
リンクのコピー

5.6.2.4. YAML を使用したデフォルト実装チャネルの作成
リンクのコピー

5.6.2.5. YAML を使用した Kafka チャネルの作成
リンクのコピー

5.6.2.6. 次のステップ
リンクのコピー

5.6.3. デフォルトのチャネル実装
リンクのコピー

5.6.3.1. デフォルトチャネル実装の設定
リンクのコピー

5.6.4. Knative Kafka チャネルのセキュリティー設定
リンクのコピー

5.6.4.1. Kafka チャネルの TLS 認証の設定
リンクのコピー

5.6.4.2. Kafka チャネルの SASL 認証の設定
リンクのコピー

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

多様性を受け入れるオープンソースの強化

会社概要

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

5.6. チャネル

5.6.1. チャネルおよびサブスクリプションリンクのコピーリンクがクリップボードにコピーされました!

5.6.1.1. チャネルの実装タイプリンクのコピーリンクがクリップボードにコピーされました!

5.6.2. チャネルの作成リンクのコピーリンクがクリップボードにコピーされました!

5.6.2.1. Administrator パースペクティブを使用したチャネルの作成リンクのコピーリンクがクリップボードにコピーされました!

5.6.2.2. Developer パースペクティブを使用したチャネルの作成リンクのコピーリンクがクリップボードにコピーされました!

5.6.2.3. Knative CLI を使用したチャネルの作成リンクのコピーリンクがクリップボードにコピーされました!

5.6.2.4. YAML を使用したデフォルト実装チャネルの作成リンクのコピーリンクがクリップボードにコピーされました!

5.6.2.5. YAML を使用した Kafka チャネルの作成リンクのコピーリンクがクリップボードにコピーされました!

5.6.2.6. 次のステップリンクのコピーリンクがクリップボードにコピーされました!

5.6.3. デフォルトのチャネル実装リンクのコピーリンクがクリップボードにコピーされました!

5.6.3.1. デフォルトチャネル実装の設定リンクのコピーリンクがクリップボードにコピーされました!

5.6.4. Knative Kafka チャネルのセキュリティー設定リンクのコピーリンクがクリップボードにコピーされました!

5.6.4.1. Kafka チャネルの TLS 認証の設定リンクのコピーリンクがクリップボードにコピーされました!

5.6.4.2. Kafka チャネルの SASL 認証の設定リンクのコピーリンクがクリップボードにコピーされました!

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

多様性を受け入れるオープンソースの強化

会社概要

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

5.6.1. チャネルおよびサブスクリプション
リンクのコピー

5.6.1.1. チャネルの実装タイプ
リンクのコピー

5.6.2. チャネルの作成
リンクのコピー

5.6.2.1. Administrator パースペクティブを使用したチャネルの作成
リンクのコピー

5.6.2.2. Developer パースペクティブを使用したチャネルの作成
リンクのコピー

5.6.2.3. Knative CLI を使用したチャネルの作成
リンクのコピー

5.6.2.4. YAML を使用したデフォルト実装チャネルの作成
リンクのコピー

5.6.2.5. YAML を使用した Kafka チャネルの作成
リンクのコピー

5.6.2.6. 次のステップ
リンクのコピー

5.6.3. デフォルトのチャネル実装
リンクのコピー

5.6.3.1. デフォルトチャネル実装の設定
リンクのコピー

5.6.4. Knative Kafka チャネルのセキュリティー設定
リンクのコピー

5.6.4.1. Kafka チャネルの TLS 認証の設定
リンクのコピー

5.6.4.2. Kafka チャネルの SASL 認証の設定
リンクのコピー