Conexión a una instancia sin SASL
Esta sección describe cómo conectarse a una instancia de Kafka en una red privada o pública mediante una CLI, sin usar los certificados de SASL.
El acceso a la red privada y el acceso a la red pública difieren solo en las direcciones IP y los puertos de conexión. Para el acceso a la red privada, utilice el puerto 9092. Para el acceso a la red pública, utilice el puerto 9094.
A continuación se describe únicamente el procedimiento para el acceso a la red pública. Para el acceso a la red privada, reemplace las direcciones IP por las actuales.
Para las instancias compradas en julio de 2020 y posteriores, cada broker de Kafka permite un máximo de 1000 conexiones desde cada dirección IP de forma predeterminada. Para los casos adquiridos antes de julio de 2020, cada broker de Kafka permite un máximo de 200 conexiones desde cada dirección IP de forma predeterminada. El exceso de conexiones será rechazado. Puede cambiar el límite modificando los parámetros de Kafka.
Requisitos previos
- Ha configurado correctamente las reglas de grupo de seguridad. Para obtener más información, véase Tabla 1.
- Se ha obtenido la dirección de conexión de instancia.
- Para el acceso intra-VPC, utilice el puerto 9092. Obtenga la dirección de conexión de instancia en la página de detalles de instancia.
Figura 1 Obtención de direcciones de conexión de instancia Kafka para el acceso intra-VPC sin SASL
- Para acceso público, utilice el puerto 9094. Obtenga la dirección de acceso a la instancia en la página de detalles de la instancia.
Figura 2 Obtención de direcciones de conexión de instancia Kafka para acceso público sin SASL
- Para el acceso intra-VPC, utilice el puerto 9092. Obtenga la dirección de conexión de instancia en la página de detalles de instancia.
- Si la creación automática de temas no está habilitada para la instancia de Kafka, obtenga el nombre del tema.
Puede obtener el nombre del tema creado en (Opcional) Paso 3: Crear un tema en la ficha Topics de la instancia.
Figura 3 Consulta del nombre del tema
- Ha adquirido un ECS, ha instalado el JDK, ha configurado las variables de entorno y ha descargado un cliente de Kafka. Para obtener más información, consulte Paso 1: Preparar el entorno.
Creación de mensajes
Vaya al directorio /bin del archivo de cliente de Kafka y ejecute el siguiente comando para crear mensajes:
./kafka-console-producer.sh --broker-list ${connection address} --topic ${topic name}
Descripción de parámetros:
- {connection-address}: la dirección obtenida en Requisitos previos
- {topic-name}: el nombre del tema creado para la instancia de Kafka
Por ejemplo, 10.3.196.45:9094, 10.78.42.127:9094 y 10.4.49.103:9094 son las direcciones de acceso público de la instancia de Kafka.
Después de ejecutar el comando anterior, puede enviar un mensaje a la instancia de Kafka ingresando la información como se le solicite y presionando Enter. El contenido de cada línea se envía como un mensaje.
[root@ecs-kafka bin]# ./kafka-console-producer.sh --broker-list 10.3.196.45:9094,10.78.42.127:9094,10.4.49.103:9094 --topic topic-demo >Hello >DMS >Kafka! >^C[root@ecs-kafka bin]#
Para dejar de crear mensajes, presione Ctrl+C para salir.
Recuperación de mensajes
Ejecute el siguiente comando para recuperar mensajes:
./kafka-console-consumer.sh --bootstrap-server ${connection-address} --topic ${topic-name} --group ${consumer-group-name} --from-beginning
Descripción de parámetros:
- {connection-address}: la dirección obtenida en Requisitos previos
- {topic-name}: el nombre del tema creado para la instancia de Kafka
- {consumer-group-name}: el nombre del grupo de consumidores establecido en función de sus requisitos de servicio. Si se ha especificado un nombre de grupo de consumidores en el archivo de configuración, asegúrese de utilizar el mismo nombre en la línea de comandos. De lo contrario, el consumo puede fallar. Si el nombre de un grupo de consumidores comienza con un carácter especial, como un signo numérico (#), no se pueden mostrar los datos de supervisión.
A continuación se presenta un ejemplo:
[root@ecs-kafka bin]# ./kafka-console-consumer.sh --bootstrap-server 10.3.196.45:9094,10.78.42.127:9094,10.4.49.103:9094 --topic topic-demo --group order-test --from-beginning Kafka! DMS Hello ^CProcessed a total of 3 messages [root@ecs-kafka bin]#
Para detener la recuperación de mensajes, presione Ctrl+C para salir.
Acciones de seguimiento
Puede configurar las reglas de alarma para monitorear métricas para recibir notificaciones de manera oportuna cuando las instancias, los brokers o los temas son anormales.
