Kafka Connect-Konfigurationen auflisten
Listen Sie Kafka Connect-Konfigurationen im Streaming-Service auf.
Informationen zum Prüfen der Anforderungen für die Arbeit mit Kafka Connect finden Sie unter Kafka Connect verwenden.
Verwenden Sie den Befehl oci streaming admin connect-harness list und die erforderlichen Parameter, um Kafka Connect-Konfigurationen aufzulisten:
oci streaming admin connect-harness list --compartment-id <compartment_OCID>
Beispiel:
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" } ] }
Standardmäßig werden beim Abrufen einer Liste der Kafka Connect-Konfigurationen höchstens die ersten 10 Konfigurationen im Compartment zurückgegeben.
Eine vollständige Liste der Parameter und Werte für CLI-Befehle finden Sie in der CLI-Befehlsreferenz.
Führen Sie den Vorgang ListConnectHarnesses aus, um Kafka Connect-Konfigurationen aufzulisten.
SDK für Java verwenden
Das folgende Codebeispiel zeigt, wie Kafka Connect-Prozedurläufe mit dem OCI-SDK für Java aufgelistet werden:
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();
Um Kafka Connect mit Streaming verwenden zu können, benötigen Sie eine Kafka Connect-Konfiguration oder einen Kafka Connect-Prozedurlauf. Sie können die OCID für einen Prozess abrufen, wenn Sie einen neuen Prozess erstellen oder einen vorhandenen verwenden. Weitere Informationen finden Sie unter Kafka Connect verwenden.