Kafka接続構成の管理

• コンソール
• CLI
• API

• Kafka接続構成の作成

  1. コンソールのストリーミング・サービスにアクセスします。
  2. 「アナリティクス」で、「Kafka接続構成」をクリックして、既存のKafka接続構成のリストを表示します。
  3. 「Kafka接続構成の作成」をクリックします。
  4. 「コンパートメント」リストからコンパートメントを選択します。
  5. 「Kafka接続構成名」ボックスに、構成の名前を入力します。機密情報の入力は避けてください。
  6. (オプション)構成にタグを割り当てます。リソースを作成する権限がある場合、そのリソースにフリーフォーム・タグを適用する権限もあります。定義済のタグを適用するには、タグ・ネームスペースを使用する権限が必要です。タグ付けの詳細は、リソース・タグを参照してください。タグを適用するかどうかが不明な場合は、このオプションをスキップするか、管理者に連絡してください。タグは後で適用できます。
  7. 「Kafka接続構成の作成」をクリックします。
  8. 構成の詳細ページが開き、「Kafka接続ストレージ・トピック」というラベルの読取り専用テキスト・ボックスが表示されます。

     「コピー」をクリックしてコネクタ構成をコピーすると、Kafkaコネクタのconnect-distributed.propertiesファイルに貼り付けることができます。詳細は、Kafka Connectの公式ドキュメントを参照してください。

  Kafka接続構成の削除

  1. コンソールのストリーミング・サービスにアクセスします。
  2. 「アナリティクス」で、「Kafka接続構成」をクリックして、既存のKafka接続構成のリストを表示します。
  3. 削除する構成の名前をクリックします。
  4. 詳細ページで、「削除」をクリックし、「確認」をクリックします。

  別のコンパートメントへのKafka Connect構成の移動

  1. コンソールのストリーミング・サービスにアクセスします。
  2. 「アナリティクス」で、「Kafka接続構成」をクリックして、既存のKafka接続構成のリストを表示します。
  3. 移動する構成の名前をクリックします。
  4. 詳細ページで、「リソースの移動」をクリックします。
  5. 「リソースの移動」ダイアログ・ボックスで、宛先コンパートメントを選択し、「リソースの移動」をクリックします。

• CLIの使用の詳細は、コマンド・ライン・インタフェース(CLI)を参照してください。CLIコマンドで使用できるフラグおよびオプションの完全なリストは、コマンドライン・リファレンスを参照してください。

  ノート
  
  この項の例では、すべてのパラメータの完全な構文を使用しています(たとえば、--compartment-id)。一部のパラメータでは、-cなど、かわりに使用できる短縮バージョンがあります。コマンドに関連付けられている短縮パラメータのインスタンスについては、CLIのオンライン・ヘルプを参照してください。

  Kafka Connect構成のリストを取得するには

  oci streaming admin connect-harness list --compartment-id <compartment_OCID>

  例:

  oci streaming admin connect-harness list --compartment-id exampleuniqueID
  {
    "data": [
      {
        "compartment-id": "ocid1.tenancy.oc1..exampleuniqueID",
        "defined-tags": {},
        "freeform-tags": {},
        "id": "ocid1.connectharness.oc1.phx.exampleuniqueID",
        "lifecycle-state": "ACTIVE",
        "name": "MyKafkaConnectConfig",
        "time-created": "2020-08-31T17:26:09.640000+00:00"
      }
    ]
  }

  デフォルトでは、Kafka Connect構成のリストを取得すると、コンパートメントの最初の10個までの構成が返されます。

  Kafka Connect構成を作成するには

  oci streaming admin connect-harness create --name <kafka_connect_configuration_name> --compartment-id <compartment_OCID>

  例:

  oci streaming admin connect-harness create --name MyKafkaConnectConfig --compartment-id exampleuniqueID
  {
    "data": {
      "compartment-id": "ocid1.tenancy.oc1..exampleuniqueID",
      "defined-tags": {},
      "freeform-tags": {},
      "id": "ocid1.connectharness.oc1.phx.exampleuniqueID",
      "lifecycle-state": "CREATING",
      "lifecycle-state-details": null,
      "name": "MyKafkaConnectConfig",
      "time-created": "2020-11-04T17:36:44.323000+00:00"
    },
    "etag": "\"48886b1f-333f-4142-a335-ed42e88b37f8-0e7d329d-c6df-47fc-b814-f1237b414281\""
  }

  Kafka Connect構成の詳細を表示するには

  oci streaming admin connect-harness get --connect-harness-id <kafka_connect_configuration_OCID>

  例:

  oci streaming admin connect-harness get --connect-harness-id exampleuniqueID
  {
    "data": {
      "compartment-id": "ocid1.tenancy.oc1..exampleuniqueID",
      "defined-tags": {},
      "freeform-tags": {},
      "id": "ocid1.connectharness.oc1.phx.exampleuniqueID",
      "lifecycle-state": "ACTIVE",
      "lifecycle-state-details": null,
      "name": "MyKafkaConnectConfig",
      "time-created": "2020-08-31T17:26:09.640000+00:00"
    },
    "etag": "\"5cca5a19-ad06-42f4-b11e-3945d1b0ece5-a3cec7b6-7b84-4056-b411-10fd9f4b1763\""
  }

  Kafka Connect構成を更新するには

  oci streaming admin connect-harness update --connect-harness-id <kafka_connect_configuration_OCID> --defined-tags <JSON_tags>

  例:

  oci streaming admin connect-harness update --connect-harness-id exampleuniqueid --defined-tags "{\"tagNamespace\": {\"tagKey1\": \"tagValue1\",\"tagKey2\": \"tagValue2\"}}"
  WARNING: Updates to freeform-tags and defined-tags will replace any existing values. Are you sure you want to continue? [y/N]: y 

  yを選択し、[Enter]を押します。Kafka Connect構成が更新されます:

  {
    "data": {
      "compartment-id": "ocid1.tenancy.oc1..exampleuniqueID",
      "defined-tags": {
        "tagNamespace": {
          "tagKey1": "tagValue1",
          "tagKey2": "tagValue2"
        }
      },
      "freeform-tags": {},
      "id": "ocid1.connectharness.oc1.phx.exampleuniqueID",
      "lifecycle-state": "UPDATING",
      "lifecycle-state-details": null,
      "name": "MyKafkaConnectConfig",
      "time-created": "2020-08-31T17:26:09.640000+00:00"
    },
    "etag": "\"f3b74455-2584-4f20-a8bd-24068b1d0cba-2f66ecee-2e34-4c92-90d6-5c643b2be3fb\""
  }

  Kafka Connect構成を削除するには

  注意
  
  

  Kafka Connect構成は即座に削除されます。削除した構成はリカバリできません。

  oci streaming admin connect-harness delete --connect-harness-id <kafka_connect_configuration_OCID>

  例:

  oci streaming admin connect-harness delete --connect-harness-id ocid1.connectharness.oc1.phx.exampleuniqueID
  Are you sure you want to delete this resource? [y/N]:

  yを選択し、[Enter]を押します。Kafka Connect構成は、それ以上プロンプトが表示されることなく削除されます。

  Kafka Connect構成を別のコンパートメントに移動するには

  oci streaming admin connect-harness change-compartment --connect-harness-id <kafka_connect_configuration_OCID> --compartment-id <target_compartment_OCID>

  例:

  oci streaming admin connect-harness change-compartment --connect-harness-id ocid1.connectharness.oc1.phx.exampleuniqueID --compartment-id ocid1.compartment.oc1..exampleuniqueID
  {
    "etag": "\"69aae3a1-e5f0-4289-bbbf-950c0fdddf2e-cbdd76e0-9a97-49be-a747-812ba28248d1\""
  }

• ストリーミングAPIは、Kafka Connect構成ハーネスをコールします。

  APIの使用およびリクエストの署名の詳細は、REST APIのドキュメントおよびセキュリティ資格証明を参照してください。SDKの詳細は、SDKおよびCLIを参照してください。

  次のAPI操作を使用して、Kafkaコネクタ構成を管理します:

  • CreateConnectHarness
  • ListConnectHarnesses
  • GetConnectHarness
  • UpdateConnectHarness
  • DeleteConnectHarness
  • ChangeConnectHarnessCompartment