ApsaraMQ for Kafka:Criar um Kafka sink connector

Pré-requisitos

• Uma instância ApsaraMQ for Kafka deve estar implantada e no estado Running. Para mais informações, consulte Purchase and deploy an instance.

• Activate EventBridge and grant permissions.

Criar uma tarefa sink connector

1. Acesse o console do ApsaraMQ for Kafka. Na página Overview, selecione uma região na seção Resource Distribution.

2. No painel de navegação à esquerda, escolha Connector Ecosystem Integration > Tasks.

3. Na página Tasks, clique em Create Task.

4. No painel Create Task, defina o Task Name e a Description, configure a tarefa conforme descrito abaixo e clique em Save.

   • Criação da tarefa

     1. Na etapa Source, selecione Message Queue for Apache Kafka como Data Provider. Configure os parâmetros a seguir e clique em Next.

        Parâmetro	Descrição	Exemplo
        Region	A região da instância Message Queue for Apache Kafka de origem.	China (Beijing)
        Kafka instance	A instância Message Queue for Apache Kafka de origem.	alikafka_post-cn-jte3****
        Topic	O tópico do qual as mensagens são consumidas.	demo-topic
        Group ID	O grupo de consumidores da instância de origem. Quick Create (recomendado): Um Group ID no formato GID_EVENTBRIDGE_xxx é criado automaticamente. Use Existing: Selecione um Group ID existente. Não compartilhe este Group ID com outros serviços para evitar interrupções no consumo de mensagens.	Quick Create
        Consumer offset	O offset a partir do qual o consumo de mensagens tem início. Latest offset (latest) Earliest offset (earliest)	Latest offset (latest)
        Network configuration	O tipo de rede para roteamento de mensagens. Basic Network Self-managed Internet	Basic Network
        VPC	Obrigatório somente se Network configuration estiver definido como Self-managed Internet.	vpc-bp17fapfdj0dwzjkd****
        vSwitch	Obrigatório somente se Network configuration estiver definido como Self-managed Internet.	vsw-bp1gbjhj53hdjdkg****
        Security group	Obrigatório somente se Network configuration estiver definido como Self-managed Internet.	alikafka_pre-cn-7mz2****
        Data Format	O formato de codificação do conteúdo da mensagem. Recomenda-se Json quando não há requisitos específicos de codificação. Json: Codifica dados binários como um objeto JSON no payload usando UTF-8. Text: Codifica dados binários como uma string UTF-8 no payload. Este é o formato padrão. Binary: Codifica dados binários como uma string Base64 no payload.	Json
        Messages	Parâmetro de Advanced configuration. O número máximo de mensagens por lote. Uma requisição é enviada quando o número acumulado de mensagens atinge esse valor. Valores válidos: 1 a 10.000.	100
        Interval (Unit: Seconds)	Parâmetro de Advanced configuration. O intervalo, em segundos, em que as mensagens são agregadas e enviadas ao sink. Valores válidos: 0 a 15. O valor 0 indica que as mensagens são entregues imediatamente.	3

     2. Na etapa Filtering, defina o Pattern Content para filtrar eventos. Para mais informações, consulte event pattern.

     3. Na etapa Transformation, configure a transformação de dados para executar operações como divisão, mapeamento, enriquecimento e roteamento dinâmico. Para mais informações, consulte Use Function Compute to clean message data.

     4. Na etapa Sink, defina Service Type como ApsaraMQ for Kafka e configure os parâmetros a seguir.

        Parâmetro	Descrição	Exemplo
        Instance ID	Selecione a instância ApsaraMQ for Kafka de destino.	test
        Topic	Selecione um tópico na instância de destino.	test
        Acknowledgment Mode	Selecione o sinal de confirmação que o ApsaraMQ for Kafka envia ao cliente após receber os dados. None LeaderOnly All	None
        Message Value	O EventBridge usa uma expressão JSONPath para extrair conteúdo específico de um evento e roteá-lo ao destino. Complete Data Data Extraction Fixed Value Template	Extract from Event $.data.value
        Message Key	O EventBridge usa uma expressão JSONPath para extrair conteúdo específico de um evento e roteá-lo ao destino. Null Data Extraction Fixed Value Template	Extract from Event $.data.key

   • Propriedades da tarefa

     Configure a política de nova tentativa e a fila de mensagens mortas para esta tarefa. Para mais informações, consulte Retry and dead-letter queues.

5. Na página Tasks, localize sua tarefa e clique em Enable na coluna Actions.

6. Na caixa de diálogo Note, leia a mensagem e clique em OK.

   A tarefa leva de 30 a 60 segundos para iniciar após ser ativada. Acompanhe o progresso da inicialização na coluna Status da página Tasks.

Outras operações

Na página Tasks, localize a tarefa desejada e realize as seguintes operações na coluna Actions.

• Visualize os detalhes da tarefa: clique em Details. Na página Task, é possível consultar as informações básicas, as propriedades e as métricas de monitoramento da tarefa.

• Edite a configuração da tarefa: clique em Edit. No painel Edit Task, modifique os detalhes e as propriedades da tarefa.

• Ative ou pause a tarefa: clique em Enable ou Pause. Na caixa de diálogo Note, clique em OK.

• Exclua a tarefa: clique em Delete. Na caixa de diálogo Note, clique em OK.