Usar uma ferramenta de script Apache Kafka de código aberto para conectar ao mecanismo de streaming do Lindorm - : Central de Documentação do Alibaba Cloud

A API do mecanismo de streaming do Lindorm é totalmente compatível com a API do Apache Kafka de código aberto. Você pode usar uma ferramenta de script Apache Kafka de código aberto para conectar ao mecanismo de streaming do Lindorm. Este tópico descreve como usar uma ferramenta de script Apache Kafka de código aberto para conectar ao mecanismo de streaming do Lindorm.

Pré-requisitos

O Java Development Kit (JDK) V1.7 ou posterior está instalado.
Adicione o endereço IP do cliente à lista de permissões da instância do ApsaraDB for Lindorm (Lindorm). Para mais informações, consulte Configurar uma lista de permissões.
Obtenha o valor do Lindorm Stream Kafka Endpoint. Para mais informações, consulte Visualizar endpoints.
Nota
O Lindorm Stream Kafka Endpoint especifica um endpoint de nuvem privada virtual (VPC) do mecanismo de streaming do Lindorm. Verifique se seu aplicativo e sua instância do Lindorm estão implantados na mesma VPC.

Procedimento

Clique aqui para baixar uma ferramenta de script Apache Kafka de código aberto.
Descompacte a ferramenta de script Apache Kafka de código aberto baixada.
```
tar -zxf kafka_2.12-2.7.1.tgz
cd kafka_2.12-2.7.1
```

Crie um tópico.

./bin/kafka-topics.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --topic <Topic Name> --partitions <Number of Partitions> --create

Visualize todos os tópicos existentes.

./bin/kafka-topics.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --list

Exclua um tópico. Se você excluir um tópico, os dados do tópico também serão excluídos.

./bin/kafka-topics.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --topic <Topic Name> --delete

Leia dados de um tópico.

./bin/kafka-console-consumer.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --topic <Topic Name> --from-beginning --max-messages <Number of Messages to Read>

Grave dados em um tópico.

./bin/kafka-console-producer.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --topic <Topic Name>

Consulte o status de consumo de um grupo de consumidores.

./bin/kafka-consumer-groups.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --group <Group Name> --describe