5.6. チャネル

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

前提条件

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

前提条件

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

検証

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

  

前提条件

• 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>

前提条件

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

前提条件

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

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

前提条件

• 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: 1
      default-ch-webhook: 2
        default-ch-config: |
          clusterDefault: 3
            apiVersion: messaging.knative.dev/v1
            kind: InMemoryChannel
            spec:
              delivery:
                backoffDelay: PT0.5S
                backoffPolicy: exponential
                retry: 5
          namespaceDefaults: 4
            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 固有のデフォルトを設定すると、クラスター全体の設定が上書きされます。

前提条件

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

前提条件

• 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) をインストールしている。