2.3.3. Kafka でスキーマレジストリーを使用する
スキーマレジストリーをコンソールに統合して、Kafka データのスキーマを一元管理します。コンソールは現在、Kafka データストリームで使用されるスキーマを参照および検証する Apicurio Registry との統合をサポートしています。レジストリーへのリクエストは、OIDC を含むサポートされている方法を使用して認証できます。
スキーマレジストリーを追加するためのプレースホルダーは、examples/console/resources/console/010-Console-example.yaml に用意されています。
schemaRegistries プロパティーを使用して、コンソール設定の一部としてスキーマレジストリー接続をグローバルに定義できます。
schemaRegistries- コンソールがスキーマの検証と管理のために接続できる外部スキーマレジストリーを定義します。
authentication-
basic、bearerトークンまたはoidc認証を使用してスキーマレジストリーへのアクセスを設定します。 trustStore-
(オプション) スキーマレジストリーに接続するときに TLS 証明書を検証するトラストストアを指定します。サポートされている形式:
JKS、PEM、PKCS12。コンテンツは、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
url: <schema_registry_URL>
authentication:
oidc:
authServerUrl: <OIDC_discovery_URL>
clientId: <client_id>
clientSecret:
valueFrom:
secretKeyRef:
name: my-oidc-secret
key: client-secret
method: POST
grantType: CLIENT
trustStore:
type: JKS
content:
valueFrom:
configMapKeyRef:
name: my-oidc-configmap
key: ca.jks
password:
value: truststore-password
trustStore:
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
- スキーマレジストリーにアクセスするための認証情報。サポートされている認証方法は、以下のとおりです。
-
basic:ユーザー名とパスワードが必要です。 -
bearer:トークンが必要です。 -
oidc: 詳細は OIDC プロバイダーを使用して Kafka クラスターへのアクセスを保護する を参照してください。
-
- 4
- OIDC プロバイダーの TLS 証明書を検証するために使用されるオプションのトラストストア。サポートされている形式には、
JKS、PEM、PKCS12などがあります。トラストストアコンテンツは、ConfigMap(configMapKeyRef) またはSecret(secretKeyRef) のいずれかを使用して提供できます。 - 5
- トラストストアのオプションのパスワード。プレーンテキスト値 (示されているとおり) として、または
Secret経由で提供できます。プレーンテキスト値は実稼働環境では推奨されません。 - 6
- スキーマレジストリーの TLS 証明書を検証するために使用されるオプションのトラストストア。設定形式とソースオプションは、OIDC トラストストアの場合と同じです。