Creación de una configuración de Kafka Connect

• Consola
• CLI
• API

• 1. En la página de lista Configuraciones de Kafka Connect, seleccione Crear configuraciones de Kafka Connect. Si necesita ayuda para buscar la página de lista, consulte Listado de configuraciones de Kafka Connect.
     Se abre el cuadro de diálogo Crear configuración de Kafka Connect.
  2. Seleccione un compartimento en la lista Compartimento.
  3. En el cuadro Nombre de configuración de Kafka Connect, introduzca un nombre para la configuración. Evite introducir información confidencial.
  4. (Opcional) Agregue una o más etiquetas a la configuración de Kafka Connect: seleccione Mostrar opciones avanzadas para mostrar la sección Agregar etiquetas.
     Si tiene permisos para crear un recurso, también los tiene para aplicar etiquetas de formato libre a ese recurso. Para aplicar una etiqueta definida, debe tener permisos para utilizar el espacio de nombres de la etiqueta. Para obtener más información sobre el etiquetado, consulte Etiquetas de recursos. Si no está seguro de si aplicar etiquetas, omita esta opción o pregunte a un administrador. Puede aplicar etiquetas más tarde.
  5. Seleccione Crear configuración de Kafka Connect.
     Se abre la página de detalles de la nueva configuración de Kafka Connect. Un cuadro de texto de solo lectura con la etiqueta Temas de almacenamiento de Kafka Connect muestra la configuración del conector.
  6. Seleccione Copiar para copiar la configuración del conector a fin de pegarla en el archivo connect-distributed.properties del conector de Kafka.
     Para obtener más información, consulte la documentación oficial de Kafka Connect.

• Utilice el comando oci streaming admin connect-harness create y los parámetros necesarios para crear una configuración de Kafka Connect:

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

  Por ejemplo:

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

  Para obtener una lista completa de parámetros y valores para los comandos de la CLI, consulte la referencia de comandos de la CLI.

• Ejecute la operación CreateConnectHarness para crear una configuración de 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();
}