Kafka接続構成の作成

• コンソール
• CLI
• API

• 1. 「Kafka接続構成」リスト・ページで、「Kafka接続構成の作成」を選択します。リスト・ページの検索に関するヘルプが必要な場合は、Kafka接続構成のリストを参照してください。
     「Kafka接続構成の作成」ダイアログ・ボックスが開きます。
  2. 「コンパートメント」リストからコンパートメントを選択します。
  3. 「Kafka接続構成名」ボックスに、構成の名前を入力します。機密情報を入力しないでください。
  4. (オプション)Kafka Connect構成に1つ以上のタグを追加します: 「拡張オプションの表示」を選択して、「タグの追加」セクションを表示します。
     リソースの作成権限がある場合は、フリーフォーム・タグをそのリソースに適用する権限もあります。定義済タグを適用するには、タグ・ネームスペースを使用する権限が必要です。タグ付けの詳細は、リソース・タグを参照してください。タグを適用するかどうかがわからない場合は、このオプションをスキップするか、管理者に問い合せてください。タグは後で適用できます。
  5. 「Kafka接続構成の作成」を選択します。
     新しいKafka Connect構成の詳細ページが開きます。「Kafka Connectストレージ・トピック」というラベルの読取り専用テキスト・ボックスには、コネクタ構成がリストされます。
  6. 「コピー」を選択してコネクタ構成をコピーすると、Kafkaコネクタのconnect-distributed.propertiesファイルに貼り付けることができます。
     詳細は、Kafka Connectの公式ドキュメントを参照してください。

• Kafka Connect構成を作成するには、oci streaming admin connect-harness createコマンドおよび必要なパラメータを使用します:

  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\""
  }

  CLIコマンドのパラメータおよび値の完全なリストは、CLIコマンド・リファレンスを参照してください。

• CreateConnectHarness操作を実行して、Kafka Connect構成を作成します。

CreateConnectHarnessDetails createConnectHarnessDetails = CreateConnectHarnessDetails.builder()
    .compartmentId(compartment) //compartment where you want to create connect harness
    .name("myConnectHarness") //connect harness name
    .build();
 
CreateConnectHarnessRequest connectHarnessRequest = CreateConnectHarnessRequest.builder()
    .createConnectHarnessDetails(createConnectHarnessDetails)
    .build();
 
CreateConnectHarnessResponse createConnectHarnessResponse = streamAdminClient.createConnectHarness(connectHarnessRequest);
ConnectHarness connectHarness = createConnectHarnessResponse.getConnectHarness();
 
while (connectHarness.getLifecycleState() != ConnectHarness.LifecycleState.Active && connectHarness.getLifecycleState() != ConnectHarness.LifecycleState.Failed) {
    GetConnectHarnessRequest getConnectHarnessRequest = GetConnectHarnessRequest.builder().connectHarnessId(connectHarness.getId()).build();
     connectHarness = streamAdminClient.getConnectHarness(getConnectHarnessRequest).getConnectHarness();
}