2.3.3. Kafka でスキーマレジストリーを使用する


スキーマレジストリーをコンソールに統合して、Kafka データのスキーマを一元管理します。コンソールは現在、Kafka データストリームで使用されるスキーマを参照および検証する Apicurio Registry との統合をサポートしています。レジストリーへのリクエストは、OIDC を含むサポートされている方法を使用して認証できます。

スキーマレジストリーを追加するためのプレースホルダーは、examples/console/resources/console/010-Console-example.yaml に用意されています。

schemaRegistries プロパティーを使用して、コンソール設定の一部としてスキーマレジストリー接続をグローバルに定義できます。

schemaRegistries
コンソールがスキーマの検証と管理のために接続できる外部スキーマレジストリーを定義します。
authentication
basicbearer トークンまたは oidc 認証を使用してスキーマレジストリーへのアクセスを設定します。
trustStore
(オプション) スキーマレジストリーに接続するときに TLS 証明書を検証するトラストストアを指定します。サポートされている形式: JKSPEMPKCS12。コンテンツは、ConfigMap または Secret を使用して提供できます。

kafkaClusters.schemaRegistry プロパティーを使用して、スキーマレジストリーソースを Kafka クラスターに割り当てます。schemaRegistry の値は、schemaRegistries 配列内のエントリーの 名前 です。

OIDC 認証を使用したスキーマレジストリー設定の例

apiVersion: console.streamshub.github.com/v1alpha1
kind: Console
metadata:
  name: my-console
spec:
  hostname: my-console.<cluster_domain>
  schemaRegistries:
    - name: my-registry 
1

      url: <schema_registry_URL> 
2

      authentication: 
3

        oidc:
          authServerUrl: <OIDC_discovery_URL>
          clientId: <client_id>
          clientSecret:
            valueFrom:
              secretKeyRef:
                name: my-oidc-secret
                key: client-secret
          method: POST
          grantType: CLIENT
          trustStore: 
4

            type: JKS
            content:
              valueFrom:
                configMapKeyRef:
                  name: my-oidc-configmap
                  key: ca.jks
            password: 
5

              value: truststore-password
      trustStore: 
6

        type: PEM
        content:
          valueFrom:
            configMapKeyRef:
              name: my-apicurio-configmap
              key: cert-chain.pem
    kafkaClusters:
      - name: console-kafka
        namespace: kafka
        listener: secure
        metricsSource: my-ocp-prometheus
        schemaRegistry: my-registry
        credentials:
          kafkaUser:
            name: console-kafka-user1
  # ...

1
スキーマレジストリー接続の一意の名前。
2
スキーマレジストリー API のベース URL。これは通常、http://<host>/apis/registry/v2 などの REST エンドポイントです。
3
スキーマレジストリーにアクセスするための認証情報。サポートされている認証方法は、以下のとおりです。
4
OIDC プロバイダーの TLS 証明書を検証するために使用されるオプションのトラストストア。サポートされている形式には、JKSPEMPKCS12 などがあります。トラストストアコンテンツは、ConfigMap (configMapKeyRef) または Secret (secretKeyRef) のいずれかを使用して提供できます。
5
トラストストアのオプションのパスワード。プレーンテキスト値 (示されているとおり) として、または Secret 経由で提供できます。プレーンテキスト値は実稼働環境では推奨されません。
6
スキーマレジストリーの TLS 証明書を検証するために使用されるオプションのトラストストア。設定形式とソースオプションは、OIDC トラストストアの場合と同じです。
Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

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

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

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

Legal Notice

Theme

© 2026 Red Hat
トップに戻る