Prueba del cifrado TLS de Amazon MSK - Amazon Managed Streaming para Apache Kafka

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Prueba del cifrado TLS de Amazon MSK

En este proceso, se describe cómo probar el cifrado TLS con Amazon MSK.

Prueba del cifrado TLS
  1. Cree un equipo cliente siguiendo las instrucciones de Paso 3: creación de un equipo cliente.

  2. Instale Apache Kafka en el equipo cliente.

  3. En este ejemplo, usamos el almacén de confianza de JVM para comunicarnos con el clúster de MSK. Para ello, primero cree una carpeta denominada /tmp en el equipo cliente. Luego, vaya a la carpeta bin de la instalación de Apache Kafka y ejecute el siguiente comando. (Su ruta de JVM puede ser diferente).

    cp /usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-0.amzn2.x86_64/jre/lib/security/cacerts /tmp/kafka.client.truststore.jks
  4. Mientras esté aún en la carpeta bin de la instalación de Apache Kafka en el equipo cliente, cree un archivo de texto denominado client.properties con el siguiente contenido.

    security.protocol=SSL ssl.truststore.location=/tmp/kafka.client.truststore.jks
  5. Ejecute el siguiente comando en una máquina que lo tenga AWS CLI instalado y clusterARN reemplácelo por el ARN de su clúster.

    aws kafka get-bootstrap-brokers --cluster-arn clusterARN

    Un resultado correcto sería como el siguiente. Guarde este resultado porque lo necesita para el siguiente paso.

    { "BootstrapBrokerStringTls": "a-1.example.g7oein.c2.kafka.us-east-1.amazonaws.com:0123,a-3.example.g7oein.c2.kafka.us-east-1.amazonaws.com:0123,a-2.example.g7oein.c2.kafka.us-east-1.amazonaws.com:0123" }
  6. Ejecute el siguiente comando y BootstrapBrokerStringTls reemplácelo por uno de los puntos finales del broker que obtuvo en el paso anterior.

    <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list BootstrapBrokerStringTls --producer.config client.properties --topic TLSTestTopic
  7. Abra una nueva ventana de comandos y conéctese al mismo equipo cliente. A continuación, ejecute el siguiente comando para crear un consumidor de consola.

    <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server BootstrapBrokerStringTls --consumer.config client.properties --topic TLSTestTopic
  8. En la ventana del productor, escriba un mensaje de texto seguido de una devolución y busque el mismo mensaje en la ventana del consumidor. Amazon MSK cifró este mensaje en tránsito.

Para obtener más información acerca de cómo configurar clientes Apache Kafka para que funcionen con datos cifrados, consulte Configuración de clientes Kafka.