Creazione di una configurazione di Kafka Connect

• Console
• CLIENTE
• API

• 1. Nella pagina di elenco Configurazioni di Kafka Connect, selezionare Crea configurazioni di Kafka Connect. Per informazioni su come trovare la pagina dell'elenco, vedere Elenco delle configurazioni di Kafka Connect.
     Viene visualizzata la finestra di dialogo Crea configurazione Kafka Connect.
  2. Selezionare un compartimento dalla lista Compartimento.
  3. Nella casella Nome configurazione di Kafka Connect, immettere un nome per la configurazione. Evitare di fornire informazioni riservate.
  4. (Facoltativo) Aggiungere una o più tag alla configurazione di Kafka Connect: selezionare Mostra opzioni avanzate per visualizzare la sezione Aggiungi tag.
     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 configurazione di Kafka Connect.
     Viene visualizzata la pagina dei dettagli per la nuova configurazione Kafka Connect. Una casella di testo di sola lettura con l'etichetta Argomenti di memorizzazione 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 della CLI, vedere il manuale CLI Command Reference.

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

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