Documentation Oracle Cloud Infrastructure

Création d'une configuration Kafka Connect

Créez une configuration Kafka Connect dans le service Streaming.

Afin de vérifier les conditions requises pour utiliser Kafka Connect, reportez-vous à Utilisation de Kafka Connect.

    1. Sur la page de liste Configurations Kafka Connect, sélectionnez Créer une configuration Kafka Connect. Si vous avez besoin d'aide pour trouver la page de liste, reportez-vous à Liste des configurations Kafka Connect.
      Le panneau Créer une configuration Kafka Connect s'ouvre.
    2. Entrez le nom de la configuration. Evitez de saisir des informations confidentielles.
    3. Sélectionnez un compartiment pour la configuration.
    4. (Facultatif) Dans la section Balises, ajoutez des balises à la configuration Kafka Connect.
      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 Create (Créer).
      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 des valeurs des commandes de la CLI, reportez-vous à Référence des commandes de la CLI.

  • Exécutez l'opération CreateConnectHarness pour créer une configuration Kafka Connect.

Utilisation du kit SDK pour Java

L'exemple de code suivant montre comment créer un outil Kafka Connect à l'aide du kit SDK OCI pour Java :

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

Pour utiliser Kafka Connect avec Streaming, vous avez besoin d'une configuration Kafka Connect ou d'un outil Kafka Connect. Vous pouvez extraire l'OCID d'un outil lorsque vous créez un nouveau harnais ou utilisez un outil existant. Pour plus d'informations, reportez-vous à l'utilisation de Kafka Connect.