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.
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.