Création d'une configuration Kafka Connect

• Console
• CLI
• API

• 1. Sur la page de liste Configurations Kafka Connect, sélectionnez Créer des configurations Kafka Connect. Si vous avez besoin d'aide pour trouver la page de liste, reportez-vous à Liste des configurations Kafka Connect.
     La boîte de dialogue Créer une configuration Kafka Connect s'ouvre.
  2. Sélectionnez un compartiment dans la liste Compartiment.
  3. Dans la zone Nom de la configuration Kafka Connect, entrez le nom de la configuration. Evitez de saisir des informations confidentielles.
  4. (Facultatif) Ajoutez des balises à la configuration Kafka Connect : sélectionnez Afficher les options avancées pour afficher la section Ajouter des balises.
     Si vous disposez des droits d'accès nécessaires pour créer une ressource, vous pouvez également lui appliquer des balises à forme libre. Pour appliquer une balise defined, vous devez être autorisé à utiliser la balise namespace. Pour plus d'informations sur le balisage, reportez-vous à Balises de ressource. Si vous n'êtes pas sûr d'appliquer des balises, ignorez cette option ou demandez à un administrateur. Vous pouvez appliquer des balises ultérieurement.
  5. Sélectionnez Créer une configuration Kafka Connect.
     La page de détails de la nouvelle configuration Kafka Connect s'ouvre. Une zone de texte en lecture seule intitulée Rubriques relatives au stockage Kafka Connect répertorie la configuration du connecteur.
  6. Sélectionnez Copier pour copier la configuration de connecteur afin de pouvoir la coller dans le fichier connect-distributed.properties du connecteur Kafka.
     Pour plus d'informations, reportez-vous à la documentation officielle de Kafka Connect.

• Utilisez la commande oci streaming admin connect-harness create et les paramètres requis pour créer une configuration Kafka Connect :

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

  Exemple :

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

  Pour obtenir la liste complète des paramètres et valeurs des commandes de la CLI, reportez-vous à la référence des commandes de la CLI.

• Exécutez l'opération CreateConnectHarness pour créer une configuration 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();
}