Liste des configurations Kafka Connect

Répertorier les configurations Kafka Connect dans le service de diffusion en continu.

Pour connaître les conditions requises pour utiliser Kafka Connect, voir Utilisation de Kafka Connect.

    1. Ouvrez le menu de navigation et sélectionnez Analyse et intelligence artificielle. Sous Messagerie, sélectionnez Diffusion en continu.
    2. Sous Analyses, sélectionnez Configurations Kafka Connect.
    3. Pour voir les configurations Kafka Connect dans un autre compartiment, utilisez le filtre Compartiment pour changer de compartiment.
      Vous devez être autorisé à travailler dans un compartiment pour voir les ressources qu'il contient. Si vous n'êtes pas certain du compartiment à utiliser, communiquez avec un administrateur. Pour plus d'informations, voir Présentation des compartiments.
  • Utilisez la commande oci streaming admin connect-harness list et les paramètres requis pour lister les configurations Kafka Connect :

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

    Par exemple :

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

    Par défaut, l'obtention d'une liste des configurations Kafka Connect retourne les 10 premières configurations dans le compartiment.

    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 ListConnectHarnesses pour lister les configurations Kafka Connect.

Utilisation de la trousse SDK pour Java

L'exemple de code suivant montre comment lister les ensembles de tests Kafka Connect à l'aide de la trousse SDK OCI pour Java :

ListConnectHarnessesRequest listConnectHarnessesRequest = ListConnectHarnessesRequest.builder()
    .compartmentId(compartment) // compartment id to list all the connect harnesses.
    .lifecycleState(ConnectHarnessSummary.LifecycleState.Active)
    .build();
 
ListConnectHarnessesResponse listConnectHarnessesResponse = streamAdminClient.listConnectHarnesses(listConnectHarnessesRequest);
List<ConnectHarnessSummary> items = listConnectHarnessesResponse.getItems();

Pour utiliser Kafka Connect avec le service de flux, vous avez besoin d'une configuration Kafka Connect ou de l'ensemble de tests Kafka Connect. Vous pouvez extraire l'OCID d'un faisceau lorsque vous créez un nouveau faisceau ou que vous utilisez un faisceau existant. Pour plus d'informations, voir Utilisation d'une connexion Kafka.