Criando uma Configuração do Kafka Connect

• Console
• CLI
• API

• 1. Na página da lista Configurações do Kafka Connect, selecione Criar Configurações do Kafka Connect. Se precisar de ajuda para localizar a página da lista, consulte Listando Configurações do Kafka Connect.
     A caixa de diálogo Criar Configuração do Kafka Connect é aberta.
  2. Selecione um compartimento na lista Compartimento.
  3. Na caixa Nome da Configuração do Kafka Connect, informe um nome para a configuração. Evite digitar informações confidenciais.
  4. (Opcional) Adicione uma ou mais tags à configuração do Kafka Connect: Selecione Mostrar Opções Avançadas para mostrar a seção Adicionar Tags.
     Se você tiver permissões para criar um recurso, também terá permissões para aplicar tags de formato livre a esse recurso. Para aplicar uma tag definida, você deverá ter permissões para usar o namespace da tag. Para obter mais informações sobre tags, consulte Tags de Recursos. Se você não tiver certeza se deseja aplicar tags, ignore esta opção ou pergunte a um administrador. Você pode aplicar tags posteriormente.
  5. Selecione Criar Configuração do Kafka Connect.
     A página de detalhes da nova configuração do Kafka Connect é aberta. Uma caixa de texto somente leitura identificada como Tópicos de Armazenamento do Kafka Connect lista a configuração do conector.
  6. Selecione Copiar para copiar a configuração do conector, de forma que você possa colá-la no arquivo connect-distributed.properties do seu conector Kafka.
     Para obter mais informações, consulte a documentação oficial do Kafka Connect.

• Use o comando oci streaming admin connect-harness create e os parâmetros necessários para criar uma configuração do Kafka Connect:

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

  Por exemplo:

  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 obter uma lista completa de parâmetros e valores para comandos da CLI, consulte a Referência de Comandos da CLI..

• Execute a operação CreateConnectHarness para criar uma configuração do 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();
}