Acceso a una instancia de Kafka con SASL

Prerrequisitos:

• Las reglas del grupo de seguridad se han configurado correctamente.

  Se puede acceder a una instancia de Kafka con SASL habilitado dentro de una VPC o a través de redes públicas. Asegúrese de que las reglas del grupo de seguridad se hayan configurado correctamente para la instancia. Para obtener más información acerca de los requisitos de configuración del grupo de seguridad, consulte Tabla 2.

• Se ha obtenido la dirección de conexión de instancia.
  • Para el acceso intra-VPC, utilice el puerto 9093. 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 con SASL habilitado
    
  • Para acceso público, utilice el puerto 9095. 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 con SASL habilitado
    

• Se ha creado un tema para la instancia de Kafka. De lo contrario, cree un tema según las instrucciones Cómo crear un tema.
• Se ha descargado el certificado client.jks. Haga clic en la instancia de Kafka para ir a la página Basic Information. Haga clic en Download junto a SSL Certificate en el área Connection. Descargue y descomprima el paquete para obtener el archivo de certificado de cliente client.jks.
• Kafka CLI v1.1.0, v2.7, or v2.3.0 está disponible. Asegúrese de que la instancia de Kafka y la CLI son de la misma versión.
• Se ha creado un ECS y sus configuraciones de VPC, subred y grupo de seguridad son las mismas que las de la instancia de Kafka. JDK v1.8.111 o posterior se ha instalado en ECS y se han configurado las variables de entorno relacionadas.

Acceso a la instancia mediante CLI

Lo siguiente usa Linux como ejemplo.

1. Descomprima el paquete Kafka CLI.Acceda al directorio donde está almacenado el paquete CLI y ejecute el siguiente comando para descomprimir el paquete:

   tar -zxf [kafka_tar]

   En el comando anterior, [kafka_tar] indica el nombre del paquete CLI.

   Por ejemplo:

   tar -zxf kafka_2.11-2.3.0.tgz

2. Modifique el archivo de configuración de la CLI de Kafka.Busque los archivos consumer.properties y producer.properties en el directorio /config de la CLI de Kafka y agregue el siguiente contenido a los archivos:

   sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
   username="**********" \
   password="**********";        
   sasl.mechanism=PLAIN
   
   security.protocol=SASL_SSL
   ssl.truststore.location=/opt/kafka_2.11-2.3.0/config/client.jks
   ssl.truststore.password=dms@kafka
   ssl.endpoint.identification.algorithm=

   Descripción del parámetro:

   • nombre de usuario y contraseña se establecen cuando se habilita Kafka SASL_SSL durante la creación de instancia o cuando se crea un usuario SASL_SSL.
   • ssl.truststore.location: ruta para almacenar el certificado client.jks. Incluso en Windows, necesita usar barras diagonales (/) para la ruta del certificado. No utilice barras diagonales invertidas (\), que se utilizan de forma predeterminada para las rutas en Windows. De lo contrario, el cliente no obtendrá el certificado.
   • ssl.truststore.password: contraseña del certificado del servidor, que debe establecerse en dms@kafka y no se puede cambiar.
   • ssl.endpoint.identification.algorithm: si se debe verificar el nombre de dominio del certificado. Este parámetro debe dejarse en blanco, lo que indica la desactivación de la verificación del nombre de dominio.

3. Acceda al directorio /bin de la CLI de Kafka.

   En Windows, necesita acceder al directorio /bin/windows.

4. Ejecute el siguiente comando para crear mensajes:

   ./kafka-console-producer.sh --broker-list ${connection-address} --topic ${topic-name} --producer.config ../config/producer.properties

   Descripción del parámetro:

   • {connection-address}: la dirección obtenida en Prerrequisitos. Para el acceso público, utilice Instance Address (Public Network). Para el acceso intra-VPC, utilice Instance Address (Private Network).
   • {topic-name}: el nombre del tema creado para la instancia de Kafka

   En el siguiente ejemplo se usan direcciones de conexión 10.xxx.xxx.202:9095,10.xxx.xxx.197:9095,10.xxx.xxx.68:9095.

   Después de ejecutar el comando anterior, puede enviar un mensaje a la instancia de Kafka escribiéndolo y presionando Enter. Cada línea de contenido se envía como un mensaje.

   [root@ecs-kafka bin]#./kafka-console-producer.sh --broker-list 10.xxx.xxx.202:9095,10.xxx.xxx.197:9095,10.xxx.xxx.68:9095  --topic topic-demo --producer.config ../config/producer.properties
   >hello
   >DMS
   >Kafka!
   >^C[root@ecs-kafka bin]# 

   Para dejar de crear mensajes, presione Ctrl+C para salir.

5. Ejecute el siguiente comando para recuperar mensajes:

   ./kafka-console-consumer.sh --bootstrap-server ${connection-address} --topic ${topic-name} --group ${consumer-group-name} --from-beginning  --consumer.config ../config/consumer.properties

   Descripción del parámetro:

   • {connection-address}: la dirección obtenida en Prerrequisitos. Para el acceso público, utilice Instance Address (Public Network). Para el acceso intra-VPC, utilice Instance Address (Private Network).
   • {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. Asegúrese de que el nombre del grupo de consumidores en la línea de comandos es el mismo que el especificado en el archivo de configuración, si lo hay. De lo contrario, la recuperación de mensajes puede fallar.

   Ejemplo:

   [root@ecs-kafka bin]#  ./kafka-console-consumer.sh --bootstrap-server 10.xxx.xxx.202:9095,10.xxx.xxx.197:9095,10.xxx.xxx.68:9095 --topic topic-demo --group order-test --from-beginning --consumer.config ../config/consumer.properties
   hello
   Kafka!
   DMS
   hello
   ^CProcessed a total of 4 messages
   [root@ecs-kafka bin]# 

   Para detener la recuperación de mensajes, presione Ctrl+C para salir.