Création d'une configuration Kafka Connect

• Console
• Interface de ligne de commande
• API

• 1. Dans 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, voir 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 des compartiments.
  3. Dans la zone Nom de la configuration Kafka Connect, entrez un nom pour la configuration. Évitez d'entrer des informations confidentielles.
  4. (Facultatif) Ajoutez un ou plusieurs marqueurs à la configuration Kafka Connect : Sélectionnez Afficher les options avancées pour afficher la section Ajouter des marqueurs.
     Si vous avez l'autorisation de créer une ressource, vous avez également l'autorisation d'appliquer des marqueurs à structure libre à cette ressource. Pour appliquer un marqueur défini, vous devez être autorisé à utiliser l'espace de noms de marqueur. Pour plus d'informations sur le marquage, voir Marqueurs de ressource. Si vous ne savez pas si vous devez appliquer des marqueurs, ignorez cette option ou demandez à un administrateur. Vous pouvez appliquer des marqueurs plus tard.
  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 sur le stockage Kafka Connect répertorie la configuration du connecteur.
  6. Sélectionnez Copier pour copier la configuration du connecteur afin de pouvoir la copier dans le fichier connect-distributed.properties pour votre connecteur Kafka.
     Pour plus d'informations, consultez la documentation officielle relative à 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>

  Par 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 la liste complète des paramètres et des valeurs pour les commandes de l'interface de ligne de commande, voir .

• 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();
}