Documentazione dell'infrastruttura Oracle Cloud

Creazione di una configurazione di Kafka Connect

Creare una configurazione Kafka Connect nel servizio di streaming.

Per esaminare i requisiti per l'utilizzo di Kafka Connect, vedere Uso di Kafka Connect.

    1. Nella pagina elenco Configurazioni Kafka Connect selezionare Crea configurazione Kafka Connect. Per assistenza nella ricerca della pagina di elenco, vedere Elenco delle configurazioni di Kafka Connect.
      Viene visualizzato il pannello Crea configurazione Kafka Connect.
    2. Immettere un nome per la configurazione. Evitare di fornire informazioni riservate.
    3. Selezionare il compartimento per la configurazione.
    4. (Facoltativo) Nella sezione Tag aggiungere una o più tag alla configurazione di Kafka Connect.
      Se si dispone delle autorizzazioni per creare una risorsa, si dispone anche delle autorizzazioni per applicare le tag in formato libero a tale risorsa. Per applicare una tag defined, è necessario disporre delle autorizzazioni per utilizzare la tag namespace. Per ulteriori informazioni sull'applicazione di tag, vedere Tag risorsa. Se non si è certi di applicare le tag, saltare questa opzione o chiedere a un amministratore. È possibile applicare le tag in un secondo momento.
    5. Selezionare Crea.
      Viene visualizzata la pagina dei dettagli per la nuova configurazione di Kafka Connect. Una casella di testo di sola lettura con etichetta Argomenti relativi allo storage Kafka Connect elenca la configurazione del connettore.
    6. Selezionare Copia per copiare la configurazione del connettore in modo da poterla incollare nel file connect-distributed.properties per il connettore Kafka.
      Per ulteriori informazioni, consultare la documentazione ufficiale di Kafka Connect.

  • Utilizzare il comando oci streaming admin connect-harness create e i parametri richiesti per creare una configurazione di Kafka Connect:

    oci streaming admin connect-harness create --name <kafka_connect_configuration_name> --compartment-id <compartment_OCID>

    Ad esempio:

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

    Per un elenco completo dei parametri e dei valori per i comandi CLI, consultare il manuale CLI Command Reference.

  • Eseguire l'operazione CreateConnectHarness per creare una configurazione di Kafka Connect.

Utilizzo dell'SDK per Java

L'esempio di codice riportato di seguito mostra come creare una struttura Kafka Connect utilizzando l'SDK OCI per 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();
}

Per utilizzare Kafka Connect con Streaming, è necessaria una configurazione Kafka Connect o un harness Kafka Connect. È possibile recuperare l'OCID per una cintura quando si crea una nuova cintura o ne si utilizza una esistente. Per ulteriori informazioni, vedere Uso di Kafka Connect.