Creación de un secreto con las credenciales necesarias para los ejemplos de Kafka

Antes de crear la aplicación Code Engine para enviar mensajes Kafka, cree un secreto Code Engine que contenga las credenciales necesarias.

Antes de empezar

• Determine el proyecto Code Engine que desea utilizar y asegúrese de que este proyecto esté seleccionado. Consulte Crear y trabajar con un proyecto.

Para simplificar este escenario, crea un secreto, kafka-subscription-secret, que contenga las credenciales necesarias tanto para la aplicación de ejemplo del remitente Kafka como para la suscripción a eventos Kafka, que utiliza la aplicación de ejemplo del receptor Kafka. Estas credenciales son necesarias para que la aplicación de envío de ejemplo Kafka y la suscripción al evento Code Engine Kafka puedan comunicarse con la instancia del servicio Event Streams. Aunque no es obligatorio crear este secreto antes de crear la aplicación de envío de Kafka y la suscripción al evento, esta acción simplifica los pasos necesarios.

Creación de una aplicación Code Engine para enviar sucesos

Crea una aplicación « Code Engine » para conectarte a tu instancia de Event Streams y generar (enviar) mensajes Kafka a un destinatario de mensajes Kafka (consumidor Kafka ).

Creación de una aplicación Code Engine para recibir sucesos de Kafka desde la consola

1. Cree una aplicación Code Engine para que actúe como consumidor de sucesos de los mensajes Kafka y reciba los sucesos Kafka. Por ejemplo, cree una aplicación denominada kafka-receiver-app que utilice la imagen icr.io/codeengine/kafka-receiver. Esta imagen se crea a partir de receiver.go, que está disponible en el GitHub de Samples for IBM Cloud Code Engine. Este ejemplo no requiere ninguna variable de entorno.
2. Después de desplegar esta app, confirme que está en estado ready.

Al utilizar la consola, no es necesario que la aplicación o el trabajo que se utiliza para recibir eventos de « Kafka » ya exista antes de crear la suscripción al evento « Kafka ». Sin embargo, si la aplicación o el trabajo no existen al crear la suscripción de suceso, el estado de la suscripción refleja que el consumidor no existe. Debe crear la aplicación o el trabajo antes de que la suscripción esté en un estado preparado y pueda recibir sucesos a través de esta suscripción.

Creación de una suscripción de suceso de Code Engine Kafka para una app desde la consola

La suscripción a eventos de « Kafka » define la relación entre el productor (remitente) y el consumidor (destinatario) de eventos de « Kafka ».

Antes de empezar

• Determine el proyecto Code Engine que desea utilizar y asegúrese de que este proyecto esté seleccionado. Consulte Crear y trabajar con un proyecto.

Sigue los siguientes pasos para crear una suscripción a eventos de « Kafka » para una aplicación desde la consola.

1. Desde la página «Proyectos» de Code Engine, accede a tu proyecto.
2. En la página Visión general, pulse Suscripciones de sucesos.
3. En la página Suscripciones de sucesos, pulse Crear para crear la suscripción.
4. En la página Crear una suscripción de suceso, seleccione el mosaico Event Streams / Kafka para especificar el tipo de suceso.
5. Para General, proporcione un nombre para la suscripción de Event Streams / Kafka. Pulse Siguiente para continuar.
6. Para obtener más información sobre Message Broker,
   1. Especifica los servidores del agente de mensajes « Kafka » correspondientes a las colas de mensajes desde las que se reciben los mensajes como eventos a través de esta suscripción. Para obtener información sobre los hosts de intermediario, temas y credenciales de acceso, consulte los detalles de credenciales de servicio para la instancia de servicio en la consola de Event Streams. Por ejemplo, especifique "broker-0-abcdabcdabcdabcd.kafka.svc01.us-south.eventstreams.cloud.ibm.com:9093", "broker-1-abcdabcdabcdabcd.kafka.svc01.us-south.eventstreams.cloud.ibm.com:9093" para los hosts de intermediario de mensajes para la instancia de servicio de myeventstream-key. Puede encontrar los intermediarios para la instancia de servicio en Event Streams en el campo Kafka_brokers_sasl.
   2. Pulse Configurar para configurar el acceso al intermediario de mensajes. Para autenticarse desde Code Engine en la instancia de Kafka o Event Streams, debe proporcionar un secreto de acceso de intermediario de mensajes.
      • Puede crear un nuevo secreto, elegir un secreto existente o, si no son necesarias las credenciales para acceder a los intermediarios de mensajes, elegir None.
      • Para crear un secreto, pulse Crear. Proporcione un nombre para el secreto y valores para username y password. Los valores de username y password deben coincidir con los valores de las credenciales de servicio para la instancia de Kafka o Event Streams. Por ejemplo, el valor de username es el valor de user que se lista en los detalles de las credenciales de servicio en la instancia de servicio de Event Streams. El valor de password es el valor de apikey que se lista en los detalles de las credenciales de servicio en la instancia de servicio de Event Streams.
      • Para este ejemplo, utilice el secreto kafka-subscription-secret existente que se ha creado anteriormente.
   3. Especifique el nombre de los temas existentes para las colas de mensajes. Por ejemplo, kafka-topic1. Para obtener información sobre los temas existentes para la instancia de servicio, vaya a la instancia de servicio en la consola de Event Streams y consulte Temas.
   4. (Opcional) Especifique un grupo de consumidores. Los consumidores de mensajes Kafka se pueden agrupar en grupos de consumidores. Si utiliza grupos de consumidores, la configuración del tema controla el flujo de mensajes a los consumidores del grupo de consumidores. Siempre que se añade o se elimina un consumidor de un grupo de consumidores, el flujo de mensajes de ese tema puede cambiar. Esta acción puede hacer que los consumidores existentes ya no reciban mensajes de ese tema.
   5. Pulse Siguiente para continuar.
7. En el caso del consumidor de eventos, especifica la aplicación Code Engine para recibir eventos. Tenga en cuenta que puede elegir entre una lista de aplicaciones y trabajos definidos, o puede proporcionar un nombre para una aplicación (o trabajo) que todavía no se ha creado. No es necesario que la aplicación o el trabajo existan al crear la suscripción de sucesos con la consola. Sin embargo, cuando se crea la suscripción, el estado de la suscripción refleja que el consumidor no existe. Debe crear la aplicación o el trabajo antes de que la suscripción esté en un estado preparado y pueda recibir sucesos a través de esta suscripción. Para este ejemplo, utilice la aplicación kafka-receiver-app que hace referencia a la imagen icr.io/codeengine/kafka-receiver. Si la app no existe, proporcione el nombre de la aplicación y cree la aplicación después de crear la suscripción de Kafka. Solo para las aplicaciones, puede especificar opcionalmente una vía de acceso. De forma predeterminada, los sucesos se direccionan al URL raíz de la aplicación de destino. Puede enviar sucesos a un destino diferente dentro de la app especificando una vía de acceso. Por ejemplo, si la vía de acceso de suscripción especifica /events, los sucesos se envían a https://<base application URL>/events. Pulse Siguiente para continuar.
8. En resumen, revisa la configuración de tu suscripción a eventos de « Kafka » y realiza los cambios necesarios, si procede. Cuando estés listo, haz clic en «Crear» para crear la suscripción a « Kafka ».

Envío de sucesos a la aplicación receptora desde la consola

Ahora que ya has creado tu suscripción a eventos Kafka, que hace referencia a la aplicación kafka-receiver-app, utiliza kafka-sender-app para enviar eventos de mensajes a la aplicación receptora.

1. Inicie el registro de la aplicación receptora para ver los registros de la aplicación desde la consola para ver los sucesos.

2. (facultativo) Inicie el registro de la aplicación del remitente para ver los registros de la aplicación desde la consola para ver información sobre los sucesos que se envían.

3. Una vez iniciado el registro, llame a la aplicación kafka-sender-app con curl y especifique el URL público del kafka-sender-app, el nombre de su tema y el número de mensajes a enviar. Puede obtener la dirección pública URL de esta aplicación en la pestaña Domain mappings de su aplicación. Por ejemplo:

   curl "<public_URL_of_Kafka_sender_app>?topic=<your_topic_name>&num=<number_of_messages_to_produce>"
   

Asegúrese de ajustar el valor a curl entre comillas para asegurarse de que se trata como una sola serie.

Creación de una app Code Engine para recibir sucesos de Kafka con la CLI

Antes de empezar

• Configure su entorno de CLI de Code Engine.

• Cree y trabaje con un proyecto.

1. Cree una aplicación Code Engine para que actúe como consumidor de sucesos de los mensajes Kafka y reciba los sucesos Kafka. Por ejemplo, cree una aplicación denominada kafka-receiver-app2 que utilice la imagen icr.io/codeengine/kafka-receiver. Esta imagen se crea a partir de receiver.go, que está disponible en el GitHub de Samples for IBM Cloud Code Engine. Este ejemplo no requiere ninguna variable de entorno. Si lo deseas, puedes especificar la opción « --min-scale=1 », de modo que la aplicación siempre tenga una instancia en ejecución y no se reduzca a cero. La configuración de la app para que siempre haya una instancia de ejecución es útil cuando se ven los registros. Si está ejecutando en un entorno de producción, tenga en cuenta el coste de mantener una instancia en ejecución de la app o si desea que Code Engine se escale automáticamente a cero. De forma predeterminada, la aplicación se escala a cero cuando no se utiliza.

   ibmcloud ce app create -n kafka-receiver-app2 --image icr.io/codeengine/kafka-receiver --min-scale 1
   

   De forma predeterminada, los sucesos se direccionan al URL raíz de la aplicación de destino. Puede enviar sucesos a un destino diferente dentro de la app utilizando la opción --path. Por ejemplo, si la suscripción indica --path /event, el suceso se envía a https://<base application URL>/events.

2. Después de desplegar esta app, ejecute el mandato app get para confirmar que la app está en estado ready.

   ibmcloud ce app get -n kafka-receiver-app2
   

Creación de una suscripción de suceso de Code Engine Kafka para una app con la CLI

Puedes crear una suscripción a eventos de Kafka —que define la relación entre el productor (remitente) y el consumidor (destinatario) de eventos de Kafka — mediante la CLI.

1. Cree una suscripción de suceso de Code Engine Kafka para los sucesos de Kafka utilizando el mandato ibmcloud ce sub kafka create. Utilice el secreto de kafka-subscription-secret que ha creado anteriormente para acceder al intermediario de mensajes. Especifique la información de intermediario basada en la información de credenciales de servicio para el recurso Kafka. Para este ejemplo, puede obtener la información de intermediario de la salida del mandato ibmcloud resource service-key myeventstream-key. Tenga en cuenta que debe especificar una opción --broker para cada intermediario del tema. La opción --destination especifica el recurso Code Engine que recibe los sucesos.

   ibmcloud ce sub kafka create --name mykafkasubscription --destination kafka-receiver-app2 --secret kafka-subscription-secret --topic kafka-topic1 --broker broker-3-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093 --broker broker-5-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093 --broker  broker-0-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093 --broker broker-1-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093 --broker broker-4-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093 --broker broker-2-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   

2. Mostrar los detalles de la suscripción al evento « Kafka ».

   ibmcloud ce sub kafka get -n mykafkasubscription
   

   Salida de ejemplo

   Getting Kafka event subscription 'mykafkasubscription'...
   OK
   Name:          mykafkasubscription
   [...]
   Destination Type:                 app
   Destination:                      kafka-receiver-app2
   Brokers:
   broker-3-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   broker-5-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   broker-0-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   broker-1-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   broker-4-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   broker-2-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   Consumer Group:                   knative-kafka-source-a4072fe1-1dfa-4470-9d07-bf7a0ff8e340
   Topics:
   kafka-topic1
   Secret key reference (user):      kafka-subscription-secret.username
   Secret key reference (password):  kafka-subscription-secret.password
   Ready:                            true
   Conditions:
   Type                     OK    Age  Reason
   ConnectionEstablished    true  24s
   InitialOffsetsCommitted  true  24s
   Ready                    true  24s
   Scheduled                true  24s
   SinkProvided             true  24s
   Events:
   Type     Reason           Age  Source                  Messages
   Normal   FinalizerUpdate  26s  kafkasource-controller  Updated "mykafkasubscription" finalizers
   

Envío de sucesos a la app receptora con la CLI

Ahora que ya has creado tu suscripción a eventos Kafka, que hace referencia a la aplicación kafka-receiver-app, utiliza kafka-sender-app para enviar eventos de mensajes a la aplicación receptora.

1. Obtener la URL pública de la aplicación de destino, kafka-sender-app mediante el uso de ibmcloud ce app get Comando con el --output url Opción para encontrar la URL de tu aplicación.

   ibmcloud ce app get -n kafka-sender-app --output url
   

   Salida de ejemplo

   https://kafka-sender-app.abcdabcdabc.us-south.codeengine.appdomain.cloud
   

2. Ejecute la aplicación de generador de sucesos Kafka, kafka-sender-app para enviar sucesos a la aplicación Code Engine de destino. Llame a la aplicación kafka-sender-app con curl y especifique valores para el tema y el número de mensajes. Utiliza el resultado del ibmcloud ce app get comando para encontrar el URL público de tu aplicación. Asegúrese de ajustar el valor a curl entre comillas para asegurarse de que se trata como una sola serie.

   curl "<public_URL_of_Kafka_sender_app>?topic=<your_topic_name>&num=<number_of_messages_to_produce>"
   

   Por ejemplo:

   curl "https://kafka-sender-app.abcdabcdabc.us-south.codeengine.appdomain.cloud?topic=kafka-topic1&num=1"
   

3. Ver sucesos en registros. Cuando se crea la suscripción de sucesos de Kafka con un intermediario, temas y un secreto de acceso que son válidos, y tiene una aplicación Kafka que genera mensajes sobre ese tema (como kafka-sender-app), puede ver sucesos en los registros para la aplicación Code Engine de destino que recibe mensajes Kafka, como kafka-receiver-app. Cuando utilice la aplicación receptora Kafka (icr.io/codeengine/kafka-receiver), busque Event data en los registros de la aplicación receptora para ver los mensajes recibidos.

   ibmcloud ce app logs -n kafka-receiver-app2
   

   Salida de ejemplo

   Getting logs for all instances of application 'kafka-receiver-app2'...
   OK
   kafka-receiver-app2-00001-deployment-66976f7988-9xttm/user-container:
   2022/03/31 22:19:45 Listening on port 8080
   2022/03/31 22:19:46 ----------
   2022/03/31 22:19:46 Path: /
   2022/03/31 22:19:46 Header: Accept-Encoding=[gzip]
   2022/03/31 22:19:46 Header: Ce-Id=[partition:0/offset:167]
   2022/03/31 22:19:46 Header: Ce-Source=[/apis/v1/namespaces/glxo4k7nj7d/kafkasources/mykafkasubscription#kafka-topic1]
   2022/03/31 22:19:46 Header: Ce-Specversion=[1.0]
   2022/03/31 22:19:46 Header: Ce-Subject=[partition:0#167]
   2022/03/31 22:19:46 Header: Ce-Time=[2022-03-31T22:19:36.499Z]
   2022/03/31 22:19:46 Header: Ce-Type=[dev.knative.kafka.event]
   2022/03/31 22:19:46 Header: Content-Length=[8]
   2022/03/31 22:19:46 Header: Forwarded=[for=172.30.208.213;proto=http, for=127.0.0.6]
   2022/03/31 22:19:46 Header: K-Proxy-Request=[activator]
   2022/03/31 22:19:46 Header: Traceparent=[00-b033708685c715a7c2384cdf05797785-65540b0937e9b0ce-00]
   2022/03/31 22:19:46 Header: User-Agent=[Go-http-client/1.1]
   2022/03/31 22:19:46 Header: X-B3-Parentspanid=[e1a785d7fdbead6c]
   2022/03/31 22:19:46 Header: X-B3-Sampled=[1]
   2022/03/31 22:19:46 Header: X-B3-Spanid=[abcde9901e6bf83f]
   2022/03/31 22:19:46 Header: X-B3-Traceid=[abcde490a426573772fa0bf60caf5ddb]
   2022/03/31 22:19:46 Header: X-Envoy-Attempt-Count=[1]
   2022/03/31 22:19:46 Header: X-Forwarded-For=[172.30.208.213, 127.0.0.6, 127.0.0.6]
   2022/03/31 22:19:46 Header: X-Forwarded-Proto=[http]
   2022/03/31 22:19:46 Header: X-Request-Id=[abcdeb4e-c5ac-abcd-abcd-60e6278abcde]
   2022/03/31 22:19:46 Event data: test1: 1
   

   Ten en cuenta que la información de registro de las aplicaciones solo se conserva durante una hora. Para obtener más información sobre la visualización de registros para apps (o trabajos), consulte Visualización de registros.

Cabeceras para aplicaciones

Salida de ejemplo

Ce-Id=[partition:0/offset:0]
Ce-Source=[/apis/v1/namespaces/ewgz38l13ts/kafkasources/mykafkasubscription#kafka-topic1]
Ce-Specversion=[1.0]
Ce-Subject=[partition:0#0]
Ce-Time=[2021-09-27T16:39:01.36Z]
Ce-Type=[dev.knative.kafka.event]

HTTP cuerpo para aplicaciones

El cuerpo del mensaje « HTTP » contiene el mensaje « Kafka » y tiene el formato que se especifica al crear o actualizar la suscripción.

Creación de un trabajo Code Engine para recibir sucesos de Kafka desde la consola

1. Cree un trabajo Code Engine para actuar como consumidor de sucesos de los mensajes Kafka y recibir los sucesos Kafka. Por ejemplo, crea una tarea llamada « kafka-receiver-job » que utilice la imagen de ejemplo « icr.io/codeengine/codeengine ». Esta imagen se ha creado a partir de codeengine.go, disponible en el repositorio «Samples for IBM Cloud Code Engine »(GitHub). Este ejemplo no requiere ninguna variable de entorno.
2. Después de crear este trabajo, confirme que está en estado ready.

Al utilizar la consola, no es necesario que la aplicación o el trabajo que se utiliza para recibir eventos de « Kafka » ya exista antes de crear la suscripción al evento « Kafka ». Sin embargo, si la aplicación o el trabajo no existen al crear la suscripción de suceso, el estado de la suscripción refleja que el consumidor no existe. Debe crear la aplicación o el trabajo antes de que la suscripción esté en un estado preparado y pueda recibir sucesos a través de esta suscripción.

Creación de una suscripción de suceso de Code Engine Kafka para un trabajo desde la consola

La suscripción a eventos de « Kafka » define la relación entre el productor (remitente) y el consumidor (destinatario) de eventos de « Kafka ».

Antes de empezar

• Determine el proyecto Code Engine que desea utilizar y asegúrese de que este proyecto esté seleccionado. Consulte Crear y trabajar con un proyecto.

Sigue los siguientes pasos para crear una suscripción a eventos de « Kafka » para una aplicación desde la consola.

1. Desde la página «Proyectos» de Code Engine, accede a tu proyecto.
2. En la página Visión general, pulse Suscripciones de sucesos.
3. En la página Suscripciones de sucesos, pulse Crear para crear la suscripción.
4. En la página Crear una suscripción de suceso, seleccione el mosaico Event Streams / Kafka para especificar el tipo de suceso.
5. Para General, proporcione un nombre para la suscripción de Event Streams / Kafka. Pulse Siguiente para continuar.
6. Para obtener más información sobre Message Broker,
   1. Especifica los servidores del agente de mensajes « Kafka » correspondientes a las colas de mensajes desde las que se reciben los mensajes como eventos a través de esta suscripción. Para obtener información sobre los hosts de intermediario, temas y credenciales de acceso, consulte los detalles de credenciales de servicio para la instancia de servicio en la consola de Event Streams. Por ejemplo, especifique "broker-0-abcdabcdabcdabcd.kafka.svc01.us-south.eventstreams.cloud.ibm.com:9093", "broker-1-abcdabcdabcdabcd.kafka.svc01.us-south.eventstreams.cloud.ibm.com:9093" para los hosts de intermediario de mensajes para la instancia de servicio de myeventstream-key.
   2. Pulse Configurar para configurar el acceso al intermediario de mensajes. Para autenticarse desde Code Engine en la instancia de Kafka o Event Streams, debe proporcionar un secreto de acceso de intermediario de mensajes.
      • Puede crear un nuevo secreto, elegir un secreto existente o, si no son necesarias las credenciales para acceder a los intermediarios de mensajes, elegir None.
      • Para crear un secreto, pulse Crear. Proporcione un nombre para el secreto y valores para username y password. Los valores de username y password deben coincidir con los valores de las credenciales de servicio para la instancia de Kafka o Event Streams. Por ejemplo, el valor de username es el valor de user que se lista en los detalles de las credenciales de servicio en la instancia de servicio de Event Streams. El valor de password es el valor de apikey que se lista en los detalles de las credenciales de servicio en la instancia de servicio de Event Streams.
      • Para este ejemplo, utilice el secreto kafka-subscription-secret existente que se ha creado anteriormente.
   3. Especifique el nombre de los temas existentes para las colas de mensajes. Por ejemplo, kafka-topic1. Para obtener información sobre los temas existentes para la instancia de servicio, vaya a la instancia de servicio en la consola de Event Streams y consulte Temas.
   4. (Opcional) Especifique un grupo de consumidores. Los consumidores de mensajes Kafka se pueden agrupar en grupos de consumidores. Si utiliza grupos de consumidores, la configuración del tema controla el flujo de mensajes a los consumidores del grupo de consumidores. Siempre que se añade o se elimina un consumidor de un grupo de consumidores, el flujo de mensajes de ese tema puede cambiar. Esta acción puede hacer que los consumidores existentes ya no reciban mensajes de ese tema.
   5. Pulse Siguiente para continuar.
7. En el caso del consumidor de eventos, especifica el trabajo « Code Engine » para recibir eventos. Tenga en cuenta que puede elegir entre una lista de trabajos y aplicaciones definidos, o puede proporcionar un nombre para un trabajo (o aplicación) que todavía no se ha creado. No es necesario que la aplicación o el trabajo existan al crear la suscripción de sucesos con la consola. Sin embargo, cuando se crea la suscripción, el estado de la suscripción refleja que el consumidor no existe. Debe crear el trabajo (o aplicación) antes de que la suscripción esté en un estado preparado y pueda recibir sucesos a través de esta suscripción. Para este ejemplo, seleccione job como tipo de componente y utilice el trabajo kafka-receiver-job que hace referencia a la imagen icr.io/codeengine/codeengine como componente para recibir sucesos. Si tu trabajo aún no existe, indica el nombre del mismo y créalo una vez que hayas creado la suscripción a « Kafka ». Solo para las aplicaciones, puede especificar opcionalmente una vía de acceso. Pulse Siguiente para continuar.
8. En resumen, revisa la configuración de tu suscripción a eventos de « Kafka » y realiza los cambios necesarios, si procede. Cuando estés listo, haz clic en «Crear» para crear la suscripción a « Kafka ».

Envío de sucesos al trabajo receptor desde la consola

Ahora que ya has creado tu suscripción al evento « Kafka », que hace referencia al trabajo « kafka-receiver-job », utiliza el « kafka-sender-app » para enviar eventos de mensajes al trabajo receptor.

1. Inicie el registro del trabajo receptor para ver los registros de trabajo de la consola para ver los sucesos.

2. (facultativo) Inicie el registro de la aplicación del remitente para ver los registros de la aplicación desde la consola para ver información sobre los sucesos que se envían.

3. Una vez iniciado el registro, llame a la aplicación kafka-sender-app con curl y especifique el URL público del kafka-sender-app, el nombre de su tema y el número de mensajes a enviar. Puede obtener la dirección pública URL de esta aplicación en la pestaña Domain mappings de su aplicación. Por ejemplo:

   curl "<public_URL_of_Kafka_sender_app>?topic=<your_topic_name>&num=<number_of_messages_to_produce>"
   

Asegúrese de ajustar el valor a curl entre comillas para asegurarse de que se trata como una sola serie.

Cuando se crea la suscripción de Kafka con un intermediario, temas y un secreto de acceso que son válidos, y tiene un trabajo Kafka que genera mensajes sobre ese tema (como por ejemplo kafka-sender-app), puede ver sucesos en registros para el trabajo Code Engine que recibe mensajes Kafka, como por ejemplo kafka-receiver-job. Cuando utilice el trabajo receptor Kafka (icr.io/codeengine/codeengine), busque CE_DATA en los registros del trabajo receptor para ver los mensajes recibidos.

Creación de un trabajo Code Engine para recibir sucesos de Kafka con la CLI

Antes de empezar

• Configure su entorno de CLI de Code Engine.

• Cree y trabaje con un proyecto.

1. Cree un trabajo Code Engine para actuar como consumidor de sucesos de los mensajes Kafka y recibir los sucesos Kafka. Por ejemplo, cree un trabajo denominado kafka-receiver-job que utilice la imagen icr.io/codeengine/codeengine. Esta imagen se ha creado a partir de codeengine.go, disponible en el repositorio «Samples for IBM Cloud Code Engine »(GitHub).

   ibmcloud ce job create -n kafka-receiver-job --image icr.io/codeengine/codeengine
   

2. (opcional) Después de crear este trabajo, ejecute el mandato job get para ver información sobre este trabajo.

   ibmcloud ce job get -n kafka-receiver-job
   

Creación de una suscripción de suceso de Code Engine Kafka para un trabajo con la CLI

Puedes crear una suscripción a eventos de Kafka —que define la relación entre el productor (remitente) y el consumidor (destinatario) de eventos de Kafka — mediante la CLI.

1. Cree una suscripción de suceso de Code Engine Kafka para los sucesos de Kafka utilizando el mandato ibmcloud ce sub kafka create. Utilice el secreto de kafka-subscription-secret que ha creado anteriormente para acceder al intermediario de mensajes. Especifique la información de intermediario basada en la información de credenciales de servicio para el recurso Kafka. Para este ejemplo, puede obtener la información de intermediario de la salida del mandato ibmcloud resource service-key myeventstream-key. Tenga en cuenta que debe especificar una opción --broker para cada intermediario del tema. La opción --destination especifica el recurso Code Engine que recibe los sucesos. Cuando trabaja con un trabajo receptor, también debe especificar la opción --destination-type para especificar que el recurso es un trabajo, ya que el valor predeterminado para esta opción es app.

   ibmcloud ce sub kafka create --name mykafkasubscription-withjob --destination-type job --destination kafka-receiver-job --secret kafka-subscription-secret --topic kafka-topic1 --broker broker-3-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093 --broker broker-5-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093 --broker  broker-0-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093 --broker broker-1-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093 --broker broker-4-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093 --broker broker-2-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   

2. Mostrar los detalles de la suscripción al evento « Kafka ».

   ibmcloud ce sub kafka get -n mykafkasubscription-withjob
   

   Salida de ejemplo

   Getting Kafka event subscription 'mykafkasubscription-withjob'...
   OK
   Name:          mykafkasubscription-withjob
   [...]
   Destination Type:                 job
   Destination:                      kafka-receiver-job
   Brokers:
   broker-3-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   broker-5-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   broker-0-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   broker-1-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   broker-4-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   broker-2-abcdabcdabcdabcd.kafka.svc07.us-south.eventstreams.cloud.ibm.com:9093
   Consumer Group:                   knative-kafka-source-a4072fe1-1dfa-4470-9d07-bf7a0ff8e340
   Topics:
   kafka-topic1
   Secret key reference (user):      kafka-subscription-secret.username
   Secret key reference (password):  kafka-subscription-secret.password
   Ready:                            true
   [...]
   

Envío de sucesos al trabajo receptor con la CLI

Ahora que ya has creado tu suscripción a eventos Kafka, que hace referencia a la aplicación kafka-receiver-job, utiliza kafka-sender-app para enviar eventos de mensajes a la aplicación receptora.

1. Obtener la URL pública de la aplicación de destino, kafka-sender-app mediante el uso de ibmcloud ce app get Comando para encontrar la URL de su aplicación.

   ibmcloud ce app get -n kafka-sender-app --output url
   

   Salida de ejemplo

   https://kafka-sender-app.abcdabcdabc.us-south.codeengine.appdomain.cloud
   

2. Ejecute la aplicación de generador de sucesos Kafka, kafka-sender-app para enviar sucesos al trabajo Code Engine de destino. Llame a la aplicación kafka-sender-app con curl y especifique valores para el tema y el número de mensajes. Utilice la salida de la ibmcloud ce app get Comando para encontrar la URL pública de su aplicación productora de eventos. Asegúrese de ajustar el valor a curl entre comillas para asegurarse de que se trata como una sola serie. Por ejemplo:

   curl "<public_URL_of_Kafka_sender_app>?topic=<your_topic_name>&num=<number_of_messages_to_produce>"
   

   Por ejemplo:

   curl "https://kafka-sender-app.abcdabcdabc.us-south.codeengine.appdomain.cloud?topic=kafka-topic1&num=1"
   

3. Ver sucesos en registros. Cuando se crea la suscripción de sucesos de Kafka con un intermediario, temas y un secreto de acceso que son válidos, y tiene una app Kafka que genera mensajes sobre ese tema (como por ejemplo kafka-sender-app), puede ver sucesos en los registros para el trabajo Code Engine de destino que recibe mensajes Kafka, como por ejemplo kafka-receiver-job. Para cada mensaje que se envía utilizando curl, los sucesos de Kafka desencadenan el mismo número de ejecuciones de trabajo. Para ver los sucesos enviados a los trabajos, utilice el mandato ibmcloud ce jobrun logs.

   1. Utilice el mandato ibmcloud ce jobrun list para listar las ejecuciones de trabajo para el trabajo kafka-receiver-job.

       ibmcloud ce jobrun list --job kafka-receiver-job
       ```
   2. Utilice el mandato **`ibmcloud ce jobrun logs`** para obtener los registros de una ejecución de trabajo específica.
   
   ```txt {: pre}
       ibmcloud ce jobrun logs -n kafka-receiver-job-abcde
       ```
       Salida de ejemplo
   
       ```txt {: screen}
       Getting logs for all instances of job run 'kafka-receiver-job-abcde'...
       Getting jobrun 'kafka-receiver-job-abcde'...
       Getting instances of jobrun 'kafka-receiver-job-abcde'...
       OK
       kafka-receiver-job-abcde-0-0/kafka-receiver-job:
       Hello from helloworld! I'm a batch job! Index: 0
       Hello World from:
       . ___  __  ____  ____
       ./ __)/  \(    \(  __)
       ( (__(  O )) D ( ) _)
       .\___)\__/(____/(____)
       .____  __ _   ___  __  __ _  ____
       (  __)(  ( \ / __)(  )(  ( \(  __)
       .) _) /    /( (_ \ )( /    / ) _)
       (____)\_)__) \___/(__)\_)__)(____)
       Some Env Vars:
       --------------
       CE_DATA=test1: 2
       CE_DOMAIN=us-south.codeengine.appdomain.cloud
       CE_ID=partition:0/offset:249
       CE_JOB=kafka-receiver-job
       CE_JOBRUN=kafka-receiver-job-abcde
       CE_SOURCE=/apis/v1/namespaces/p99k7iy919d/kafkasources/kafkasub-job-ui#kafka-topic1
       CE_SPECVERSION=1.0
       CE_SUBDOMAIN=p99k7iy919d
       CE_SUBJECT=partition:0#249
       CE_TIME=2022-06-21T12:19:24.06Z
       CE_TYPE=dev.knative.kafka.event
       HOME=/root
       HOSTNAME=kafka-receiver-job-abcde-0-0
       JOB_INDEX=0
       KUBERNETES_PORT=tcp://172.21.0.1:443
       KUBERNETES_PORT_443_TCP=tcp://172.21.0.1:443
       KUBERNETES_PORT_443_TCP_ADDR=172.21.0.1
       KUBERNETES_PORT_443_TCP_PORT=443
       KUBERNETES_PORT_443_TCP_PROTO=tcp
       KUBERNETES_SERVICE_HOST=172.21.0.1
       KUBERNETES_SERVICE_PORT=443
       KUBERNETES_SERVICE_PORT_HTTPS=443
       PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin
       PWD=/
       SHLVL=1
       z=Set env var 'SHOW' to see all variables
       ```
   Cuando utilice el trabajo receptor Kafka (`icr.io/codeengine/codeengine`), busque `CE_DATA` en los registros del trabajo receptor para ver los mensajes recibidos.
   
   Ten en cuenta que la información de registro de las ejecuciones de los trabajos solo se conserva durante una hora. Para obtener más información sobre la visualización de registros para apps o trabajos, consulte [Visualización de registros](/docs/codeengine?topic=codeengine-logging).