ApsaraMQ for Kafka:Confluent CLI のインストールと使用

ステップ 1：バイナリのダウンロード

Confluent CLI インストールページからご利用のオペレーティングシステム用の Confluent CLI バイナリをダウンロードするか、以下の表の直接リンクを使用してください。

ファイルの整合性を確認するには、チェックサムファイルをダウンロードしてください。

ステップ 2：CLI を PATH に追加

PATH 環境変数を設定して、展開したバイナリを含むディレクトリを追加します。

export PATH=<path-to-cli>:$PATH

<path-to-cli> を Confluent CLI バイナリを展開したディレクトリの絶対パスに置き換えてください。

ステップ 3 (任意)：データディレクトリの変更

デフォルトでは、Confluent CLI はログとデータをローカルディレクトリに保存します。このディレクトリに十分なストレージ容量がない場合は、CONFLUENT_CURRENT 環境変数を別の場所に設定してください。

confluent

ステップ 4：インストールの確認

次のコマンドを実行します。

confluent

インストールが成功すると、以下のような情報が返されます。

confluent login \
  --url <mds-endpoint> \
  --certificate-authority-path <path-to-certificate.pem>

Identity and Access Management (IAM) ロールのリスト表示

利用可能なすべての IAM ロールをリスト表示します。IAM ロールは、RBAC に基づいてユーザーとサービスのリソースへのアクセス権限を定義します。

confluent iam rbac role list

IAM ロールの詳細表示

特定の IAM ロールの詳細を表示します。

confluent iam rbac role describe <role-name>

フラグ

ロールバインディングの作成

IAM ロールをユーザーまたはサービスプリンシパルにバインドします。

confluent iam rbac role-binding create [flags]

必須フラグ

スコープフラグ

その他のフラグ

例

ユーザー sr-read に、すべての Schema Registry のサブジェクトに対する DeveloperRead 権限を付与します。

confluent iam rbac role-binding create \
  --principal User:sr-read \
  --role DeveloperRead \
  --resource Subject:* \
  --kafka-cluster <kafka-cluster-id> \
  --schema-registry-cluster <schema-registry-cluster-id>

ユーザー sr-admin に、Schema Registry クラスターに対する SystemAdmin 権限を付与します。

confluent iam rbac role-binding create \
  --principal User:sr-admin \
  --role SystemAdmin \
  --kafka-cluster <kafka-cluster-id> \
  --schema-registry-cluster <schema-registry-cluster-id>

ロールバインディングのリスト表示

既存のロールバインディングを表示します。

confluent iam rbac role-binding list [flags]

主要なフラグ

例

Schema Registry クラスターで DeveloperRead 権限を持つすべてのユーザーをリスト表示します。

confluent iam rbac role-binding list \
  --role DeveloperRead \
  --kafka-cluster <kafka-cluster-id> \
  --schema-registry-cluster <schema-registry-cluster-id>

Schema Registry クラスターで SystemAdmin 権限を持つすべてのユーザーをリスト表示します。

confluent iam rbac role-binding list \
  --role SystemAdmin \
  --kafka-cluster <kafka-cluster-id> \
  --schema-registry-cluster <schema-registry-cluster-id>

ロールバインディングの削除

ユーザーから IAM ロールを削除します。

confluent iam rbac role-binding delete [flags]

このコマンドは role-binding create と同じフラグを使用し、さらに以下を追加します。

例

Schema Registry クラスターで、ユーザー sr-read から DeveloperRead 権限を削除します。

confluent iam rbac role-binding delete \
  --principal User:sr-read \
  --role DeveloperRead \
  --resource Subject:* \
  --kafka-cluster <kafka-cluster-id> \
  --schema-registry-cluster <schema-registry-cluster-id>

Schema Registry クラスターで、ユーザー sr-admin から SystemAdmin 権限を削除します。

confluent iam rbac role-binding delete \
  --principal User:sr-admin \
  --role SystemAdmin \
  --kafka-cluster <kafka-cluster-id> \
  --schema-registry-cluster <schema-registry-cluster-id>

ACL の作成

confluent iam acl create [flags]

必須フラグ

任意フラグ

例

IP アドレス 198.51.xx.xx のユーザー Bob に test-topic からの読み取りを許可します。

confluent iam acl create \
  --allow \
  --principal User:Bob \
  --operation READ \
  --host 198.51.xx.xx \
  --topic test-topic \
  --kafka-cluster <kafka-cluster-id>

すべてのユーザーに test-topic からの読み取りを許可しますが、ユーザー BadBob は拒否します。

# すべてのユーザーを許可
confluent iam acl create \
  --allow \
  --principal User:'*' \
  --operation READ \
  --topic test-topic \
  --kafka-cluster <kafka-cluster-id>

# BadBob を拒否 (--deny は --allow より優先されます)
confluent iam acl create \
  --deny \
  --principal User:BadBob \
  --operation READ \
  --topic test-topic \
  --kafka-cluster <kafka-cluster-id>

ACL のリスト表示

confluent iam acl list [flags]

list コマンドは、create と同じフィルタリングフラグ (--principal、--operation、--topic など) に加えて、以下を受け入れます。

例

Kafka クラスターのすべての ACL をリスト表示します。

confluent iam acl list --kafka-cluster <kafka-cluster-id>

ACL の削除

confluent iam acl delete [flags]

必須フラグ

delete コマンドは、create と同じ任意フラグ (--topic、--consumer-group、--prefix など) に加えて、以下を受け入れます。

例

ユーザー Bob が test-topic から読み取ることを許可する ACL を削除します。

confluent iam acl delete \
  --allow \
  --principal User:Bob \
  --operation READ \
  --host 198.51.xx.xx \
  --topic test-topic \
  --kafka-cluster <kafka-cluster-id>