5.6. Channels

流程

1. 在 OpenShift Container Platform Web 控制台的 Administrator 视角中，导航到 Serverless Eventing。
2. 在 Create 列表中，选择 Channel。您将被定向到 Channel 页。

3. 选择您要在 Type 列表中创建的 Channel 对象类型。

   注意

   目前默认只支持 InMemoryChannel 频道对象。如果您在 OpenShift Serverless 上安装了 Knative Kafka，则 Kafka 频道可用。

4. 点 Create。

流程

1. 在 Developer 视角中，导航到 +Add Channel。
2. 选择您要在 Type 列表中创建的 Channel 对象类型。
3. 点 Create。

流程

1. 创建一个 Channel 对象作为一个 YAML 文件：

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

   Copy to Clipboard Toggle word wrap

2. 应用 YAML 文件：

   $ oc apply -f <filename>

   Copy to Clipboard Toggle word wrap

流程

1. 创建一个 KafkaChannel 对象作为一个 YAML 文件：

   apiVersion: messaging.knative.dev/v1beta1
   kind: KafkaChannel
   metadata:
     name: example-channel
     namespace: default
   spec:
     numPartitions: 3
     replicationFactor: 1

   Copy to Clipboard Toggle word wrap
   重要

   仅支持 OpenShift Serverless 上的 KafkaChannel 对象的 v1beta1 API 版本。不要使用这个 API 的 v1alpha1 版本，因为这个版本现已弃用。

2. 应用 KafkaChannel YAML 文件：

   $ oc apply -f <filename>

   Copy to Clipboard Toggle word wrap

流程

1. 在所选命名空间中创建证书文件作为 secret：

   $ 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

   Copy to Clipboard Toggle word wrap
   重要

   使用密钥名称 ca.crt、user.crt 和 user.key。不要更改它们。

2. 编辑 KnativeKafka 自定义资源：

   $ oc edit knativekafka

   Copy to Clipboard Toggle word wrap

3. 引用您的 secret 和 secret 的命名空间：

   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

   Copy to Clipboard Toggle word wrap
   注意

   确保指定 bootstrap 服务器中的匹配端口。

   例如：

   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

   Copy to Clipboard Toggle word wrap

流程

1. 在所选命名空间中创建证书文件作为 secret：

   $ 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"

   Copy to Clipboard Toggle word wrap
   • 使用键名 ca.crt, password, 和 sasl.mechanism.不要更改它们。

   • 如果要将 SASL 与公共 CA 证书搭配使用，您必须在创建 secret 时使用 tls.enabled=true 标志，而不是使用 ca.crt 参数。例如：

     $ 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"

     Copy to Clipboard Toggle word wrap

2. 编辑 KnativeKafka 自定义资源：

   $ oc edit knativekafka

   Copy to Clipboard Toggle word wrap

3. 引用您的 secret 和 secret 的命名空间：

   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

   Copy to Clipboard Toggle word wrap
   注意

   确保指定 bootstrap 服务器中的匹配端口。

   例如：

   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

   Copy to Clipboard Toggle word wrap