Criar um conector

Criando um conector usando o AWS Management Console

1. Abra o console do Amazon MSK em https://console.aws.amazon.com/msk/.

2. No painel esquerdo, em MSK Connect, escolha Conectores.

3. Escolha Criar conector.

4. Você pode escolher entre usar um plug-in personalizado existente para criar o conector ou criar primeiro um novo plug-in personalizado. Para obter informações sobre plug-ins personalizados e como criá-los, consulte Criar plug-ins personalizados. Neste procedimento, vamos supor que você tenha um plug-in personalizado que deseja usar. Na lista de plug-ins personalizados, encontre o que você deseja usar, marque a caixa à esquerda e escolha Próximo.

5. Insira um nome e, se desejar, uma descrição.

6. Escolha o cluster ao qual deseja se conectar.

7. Especifique a configuração do conector. Os parâmetros de configuração que você precisa especificar dependerão do tipo de conector que você deseja criar. No entanto, alguns parâmetros são comuns a todos os conectores, por exemplo, os parâmetros connector.class e tasks.max. Veja a seguir um exemplo de configuração para o Conector de coletor Confluent para Amazon S3.

   connector.class=io.confluent.connect.s3.S3SinkConnector
   tasks.max=2
   topics=my-example-topic
   s3.region=us-east-1
   s3.bucket.name=amzn-s3-demo-bucket
   flush.size=1
   storage.class=io.confluent.connect.s3.storage.S3Storage
   format.class=io.confluent.connect.s3.format.json.JsonFormat
   partitioner.class=io.confluent.connect.storage.partitioner.DefaultPartitioner
   key.converter=org.apache.kafka.connect.storage.StringConverter
   value.converter=org.apache.kafka.connect.storage.StringConverter
   schema.compatibility=NONE

8. Em seguida, configure a capacidade do conector. Você pode escolher entre dois modos de capacidade: provisionado e escalonado automaticamente. Para obter informações sobre essas duas opções, consulte Saiba mais sobre a capacidade de conectores.

9. Escolha a configuração padrão do operador ou uma configuração personalizada do operador. Para obter informações sobre como criar configurações personalizadas de operador, consulte Saiba mais sobre os operadores do MSK Connect.

10. Em seguida, você especifica o perfil de execução do serviço. Essa deve ser uma função do IAM que o MSK Connect possa assumir e que conceda ao conector todas as permissões necessárias para acessar os AWS recursos necessários. Essas permissões dependem da lógica do conector. Para obter informações sobre como criar essa função, consulte Saiba mais sobre o perfil de execução do serviço.

11. Escolha Próximo, revise as informações de segurança e escolha Próximo novamente.

12. Especifique as opções de registro em log que deseja e escolha Próximo. Para obter informações sobre registro em log, consulte Registro em log no MSK Connect.

13. Escolha Criar conector.