Kafka 샘플에 필요한 신임 정보를 사용하여 시크릿 작성

Code Engine 애플리케이션을 작성하여 Kafka 메시지를 전송하기 전에 필수 신임 정보를 포함하는 Code Engine 시크릿을 작성하십시오.

시작하기 전에

• 사용할 Code Engine 프로젝트를 판별하고 이 프로젝트가 선택되었는지 확인하십시오. 프로젝트 작성 및 작업 을 참조하십시오.

이 시나리오를 간단하게 설명하기 위해, ‘ kafka-subscription-secret ’라는 하나의 시크릿을 생성하여, ‘ Kafka ’ 발신자 샘플 앱과 ‘ Kafka ’ 수신자 샘플을 사용하는 ‘ Kafka ’ 이벤트 구독 모두에 필요한 자격 증명을 포함시킵니다. 이 인증 정보는 샘플 Kafka 발신자 앱과 Code Engine Kafka 이벤트 구독이 Event Streams 서비스 인스턴스와 통신하는 데 필요합니다. Kafka 발신자 앱과 이벤트 구독을 생성하기 전에 이 시크릿을 반드시 생성해야 하는 것은 아니지만, 이렇게 하면 필요한 절차를 간소화할 수 있습니다.

이벤트를 전송할 Code Engine 앱 작성

Event Streams 인스턴스에 연결하고, Kafka 메시지를 수신하는 수신자( Kafka 소비자)에게 Kafka 메시지를 생성(전송)하는 Code Engine 앱을 생성합니다.

콘솔에서 Kafka 이벤트를 수신하도록 Code Engine 앱 작성

1. Kafka 메시지의 이벤트 이용자로 작동하고 Kafka 이벤트를 수신하도록 Code Engine 애플리케이션 을 작성하십시오. 예를 들어, icr.io/codeengine/kafka-receiver 이미지를 사용하는 kafka-receiver-app이라는 애플리케이션을 작성하십시오. 이 이미지는 receiver.go 에서 빌드되며, 이는 IBM Cloud Code Engine GitHub 저장소의 샘플에서 사용 가능합니다. 이 샘플에는 환경 변수가 필요하지 않습니다.
2. 이 앱을 배치한 후 ready 상태인지 확인하십시오.

콘솔을 사용할 때, ‘ Kafka ’ 이벤트를 수신하는 데 사용하는 앱이나 작업이 ‘ Kafka ’ 이벤트 구독을 생성하기 전에 반드시 존재해야 하는 것은 아닙니다. 그러나 이벤트 등록을 작성할 때 앱 또는 작업이 존재하지 않는 경우 등록 상태는 이용자가 존재하지 않음을 반영합니다. 등록이 준비 상태가 되기 전에 앱 또는 작업을 작성해야 하며 이 등록을 통해 이벤트를 수신할 수 있습니다.

콘솔에서 앱에 대한 Code Engine Kafka 이벤트 등록 작성

Kafka 이벤트 구독은 Kafka 의 이벤트 프로듀서(발신자)와 컨슈머(수신자) 간의 관계를 정의합니다.

시작하기 전에

• 사용할 Code Engine 프로젝트를 판별하고 이 프로젝트가 선택되었는지 확인하십시오. 프로젝트 작성 및 작업 을 참조하십시오.

콘솔에서 애플리케이션에 대한 ‘ Kafka ’ 이벤트 구독을 생성하려면 다음 단계를 따르십시오.

1. Code Engine 의 ‘프로젝트’ 페이지 에서 해당 프로젝트로 이동하세요.
2. 개요 페이지에서 이벤트 구독을 클릭하십시오.
3. 이벤트 구독 페이지에서 작성을 클릭하여 구독을 작성하십시오.
4. 이벤트 서브스크립션 작성 페이지에서 Event Streams / Kafka 타일을 선택하여 이벤트 유형을 지정하십시오.
5. 일반의 경우 Event Streams / Kafka 등록의 이름을 제공하십시오. 다음을 클릭하여 계속 진행하십시오.
6. 메시지 브로커 세부 정보 의 경우,
   1. 이 구독을 통해 이벤트로 수신되는 메시지가 포함된 메시지 큐에 대한 ‘ Kafka ’ 메시지 브로커 호스트를 지정하십시오. 브로커 호스트, 토픽 및 액세스 신임 정보에 대한 정보를 얻으려면 Event Streams 콘솔에서 서비스 인스턴스에 대한 서비스 신임 정보 세부사항을 보십시오. 예를 들어, myeventstream-key 서비스 인스턴스의 메시지 브로커 호스트에 대해 "broker-0-abcdabcdabcdabcd.kafka.svc01.us-south.eventstreams.cloud.ibm.com:9093", "broker-1-abcdabcdabcdabcd.kafka.svc01.us-south.eventstreams.cloud.ibm.com:9093" 를 지정하십시오. Kafka_brokers_sasl 필드의 Event Streams 에서 서비스 인스턴스에 대한 브로커를 찾을 수 있습니다.
   2. 구성 을 클릭하여 메시지 브로커에 대한 액세스를 구성하십시오. Code Engine 에서 Kafka 또는 Event Streams 인스턴스로 인증하려면 메시지 브로커 액세스 시크릿을 제공해야 합니다.
      • 새 시크릿을 작성하거나, 기존 시크릿을 선택하거나, 메시지 브로커에 액세스하는 데 신임 정보가 필요하지 않은 경우 None 를 선택할 수 있습니다.
      • 시크릿을 작성하려면 작성을 클릭하십시오. 시크릿의 이름과 username 및 password 의 값을 제공하십시오. username 및 password 의 값은 Kafka 또는 Event Streams 인스턴스에 대한 서비스 인증 정보의 값과 일치해야 합니다. 예를 들어, username 의 값은 Event Streams 서비스 인스턴스에서 서비스 인증 정보의 세부사항에 나열되는 user 의 값입니다. password 의 값은 Event Streams 서비스 인스턴스에서 서비스 인증 정보의 세부사항에 나열되는 apikey 의 값입니다.
      • 이 예제의 경우 이전에 작성된 기존 kafka-subscription-secret 시크릿을 사용하십시오.
   3. 메시지 큐에 대한 기존 토픽의 이름을 지정하십시오. 예를 들어, kafka-topic1입니다. 서비스 인스턴스의 기존 주제에 대한 정보를 얻으려면 Event Streams 콘솔에서 서비스 인스턴스로 이동하여 주제를 보십시오.
   4. (선택사항) 이용자 그룹을 지정하십시오. Kafka 메시지의 이용자는 이용자 그룹 으로 그룹화할 수 있습니다. 이용자 그룹을 사용 중인 경우 토픽 구성은 이용자 그룹의 이용자에 대한 메시지 플로우를 제어합니다. 이용자가 이용자 그룹에 추가되거나 이용자 그룹에서 제거될 때마다 해당 토픽의 메시지 플로우가 변경될 수 있습니다. 이 조치를 수행하면 기존 이용자가 더 이상 해당 토픽에서 메시지를 수신하지 않을 수 있습니다.
   5. 다음을 클릭하여 계속 진행하십시오.
7. 이벤트 수신자의 경우, 이벤트를 수신할 ‘ Code Engine ’ 애플리케이션을 지정하십시오. 정의된 애플리케이션 및 작업 목록에서 선택하거나 아직 작성되지 않은 앱 (또는 작업) 의 이름을 제공할 수 있습니다. 콘솔을 사용하여 이벤트 등록을 작성할 때 앱 또는 작업이 필요하지 않습니다. 그러나 구독이 작성될 때 구독의 상태는 이용자가 존재하지 않음을 반영합니다. 등록이 준비 상태가 되기 전에 앱 또는 작업을 작성해야 하며 이 등록을 통해 이벤트를 수신할 수 있습니다. 이 예에서는 icr.io/codeengine/kafka-receiver 이미지를 참조하는 kafka-receiver-app 애플리케이션이 사용됩니다. 앱이 없는 경우 Kafka 구독을 작성한 후 애플리케이션의 이름을 제공하고 애플리케이션을 작성 하십시오. 애플리케이션의 경우 선택적으로 경로를 지정할 수 있습니다. 기본적으로 이벤트는 대상 애플리케이션의 루트 URL로 라우팅됩니다. 경로를 지정하여 앱 내의 다른 대상으로 이벤트를 전송할 수 있습니다. 예를 들어, 구독 경로에 /events가 지정된 경우 이벤트가 https://<base application URL>/events로 전송됩니다. 다음을 클릭하여 계속 진행하십시오.
8. 요약하자면, ‘ Kafka ’ 이벤트 구독 설정을 검토하고 필요한 경우 변경하십시오. 준비가 되면 ‘생성’을 클릭하여 ‘ Kafka ’ 구독을 생성하세요.

콘솔에서 수신 앱으로 이벤트 전송

kafka-receiver-app 애플리케이션을 참조하는 Kafka 이벤트 구독이 생성되었으므로, kafka-sender-app 을 사용하여 수신자 애플리케이션으로 메시지 이벤트를 전송하십시오.

1. 수신자 애플리케이션에 대한 로깅을 시작하여 콘솔에서 애플리케이션 로그를 보고 이벤트를 확인하십시오.

2. (선택사항) 송신자 애플리케이션에 대한 로깅을 시작하여 콘솔에서 애플리케이션 로그를 보고 전송되는 이벤트에 대한 정보를 확인하십시오.

3. 로깅이 시작된 후 curl 으로 kafka-sender-app 애플리케이션을 호출하고 kafka-sender-app 의 공개 URL, 토픽 이름, 전송할 메시지 수를 지정합니다. 애플리케이션의 도메인 매핑 탭에서 이 애플리케이션의 공개 URL 를 얻을 수 있습니다. 예를 들면 다음과 같습니다.

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

값이 단일 문자열로 처리되도록 값을 따옴표로 묶어야 합니다.

CLI를 사용하여 Kafka 이벤트를 수신하도록 Code Engine 앱 작성

시작하기 전에

• Code Engine CLI 환경을 설정하십시오.

• 프로젝트를 작성하고 작업하십시오.

1. Kafka 메시지의 이벤트 이용자로 작동하고 Kafka 이벤트를 수신하도록 Code Engine 애플리케이션 을 작성하십시오. 예를 들어, icr.io/codeengine/kafka-receiver 이미지를 사용하는 kafka-receiver-app2이라는 애플리케이션을 작성하십시오. 이 이미지는 receiver.go 에서 빌드되며, 이는 IBM Cloud Code Engine GitHub 저장소의 샘플에서 사용 가능합니다. 이 샘플에는 환경 변수가 필요하지 않습니다. 선택적으로 --min-scale=1 옵션을 지정하면, 앱에 항상 실행 중인 인스턴스가 유지되고 인스턴스 수가 0으로 줄어들지 않도록 할 수 있습니다. 항상 실행 중인 인스턴스가 있도록 앱을 구성하면 로그를 볼 때 유용합니다. 프로덕션 환경에서 실행 중인 경우 앱의 실행 중인 인스턴스를 유지하는 비용을 고려하거나 Code Engine 에서 자동 스케일링을 0으로 설정할지 여부를 고려하십시오. 기본적으로 앱은 사용하지 않을 때 0으로 스케일링됩니다.

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

   기본적으로 이벤트는 대상 애플리케이션의 루트 URL로 라우팅됩니다. --path 옵션을 사용하여 앱 내의 다른 대상에 이벤트를 전송할 수 있습니다. 예를 들어, 구독에 --path /event가 지정된 경우 이벤트가 https://<base application URL>/events로 전송됩니다.

2. 이 앱을 배치한 후 app get 명령을 실행하여 앱이 ready 상태인지 확인하십시오.

   ibmcloud ce app get -n kafka-receiver-app2
   

CLI를 사용하여 앱에 대한 Code Engine Kafka 이벤트 등록 작성

CLI를 사용하여 이벤트의 ‘ Kafka ’ 프로듀서(발신자)와 컨슈머(수신자) 간의 관계를 정의하는 ‘ Kafka ’ 이벤트 구독을 생성할 수 있습니다.

1. ibmcloud ce sub kafka create 명령을 사용하여 Kafka 이벤트에 대한 Code Engine Kafka 이벤트 등록을 작성하십시오. 이전에 작성한 kafka-subscription-secret 시크릿을 사용하여 메시지 브로커에 액세스하십시오. Kafka 리소스에 대한 서비스 신임 정보를 기반으로 브로커 정보를 지정하십시오. 이 예의 경우, ibmcloud resource service-key myeventstream-key 명령의 출력에서 브로커 정보를 얻을 수 있습니다. 토픽의 각 브로커에 대해 --broker 옵션을 지정해야 합니다. --destination 옵션은 이벤트를 수신하는 Code Engine 자원을 지정합니다.

   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. Kafka 이벤트 구독에 대한 세부 정보를 표시합니다.

   ibmcloud ce sub kafka get -n mykafkasubscription
   

   출력 예

   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
   

CLI를 사용하여 수신 앱에 이벤트 전송

kafka-receiver-app 애플리케이션을 참조하는 Kafka 이벤트 구독이 생성되었으므로, kafka-sender-app 을 사용하여 수신자 애플리케이션으로 메시지 이벤트를 전송하십시오.

1. 명령을 사용하여 대상 앱의 공개 URL ( kafka-sender-app )를 가져옵니다 ibmcloud ce app get 명령을 --output url 옵션과 함께 사용하여 앱의 URL 을 찾습니다.

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

   출력 예

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

2. Kafka 이벤트 생성자 앱, kafka-sender-app 를 실행하여 대상 Code Engine 애플리케이션으로 이벤트를 전송하십시오. curl 를 사용하여 kafka-sender-app 애플리케이션을 호출하고 토픽에 대한 값 및 메시지 수를 지정하십시오. 다음 명령어의 출력을 사용하여 ibmcloud ce app get 명령어의 출력 결과를 사용하여 앱의 공개 URL 를 찾으세요. 값이 단일 문자열로 처리되도록 값을 따옴표로 묶어야 합니다.

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

   예를 들면 다음과 같습니다.

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

3. 로그에서 이벤트를 봅니다. Kafka 이벤트 구독이 올바른 브로커, 토픽 및 액세스 시크릿을 사용하여 작성되고 해당 토픽 (예: kafka-sender-app) 에 대한 메시지를 생성하는 Kafka 애플리케이션이 있는 경우, kafka-receiver-app 와 같은 Kafka 메시지를 수신하는 대상 Code Engine 애플리케이션에 대한 로그에서 이벤트를 볼 수 있습니다. Kafka 수신자 앱 (icr.io/codeengine/kafka-receiver) 을 사용하는 경우 수신자 애플리케이션의 로그에서 Event data 를 검색하여 수신되는 메시지를 확인하십시오.

   ibmcloud ce app logs -n kafka-receiver-app2
   

   출력 예

   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
   

   앱에 대한 로그 정보는 1시간 동안만 보관된다는 점에 유의하시기 바랍니다. 앱 (또는 작업) 의 로그 보기에 대한 자세한 정보는 로그 보기 를 참조하십시오.

앱의 헤더

출력 예

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 앱용 본문

HTTP 본문에는 Kafka 메시지가 포함되어 있으며, 이는 구독을 생성하거나 업데이트할 때 지정한 형식을 따릅니다.

콘솔에서 Kafka 이벤트를 수신하기 위한 Code Engine 작업 작성

1. Code Engine 작업 을 작성하여 Kafka 메시지의 이벤트 이용자 역할을 하고 Kafka 이벤트를 수신하십시오. 예를 들어, ‘ kafka-receiver-job ’라는 이름의 작업을 생성하고, ‘ icr.io/codeengine/codeengine ’ 샘플 이미지를 사용하도록 설정합니다. 이 이미지는 codeengine.go 에서 가져온 것으로, IBM Cloud Code Engine GitHub 저장소의 샘플 에서 확인할 수 있습니다. 이 샘플에는 환경 변수가 필요하지 않습니다.
2. 이 작업을 작성한 후 ready 상태인지 확인하십시오.

콘솔을 사용할 때, ‘ Kafka ’ 이벤트를 수신하는 데 사용하는 앱이나 작업이 ‘ Kafka ’ 이벤트 구독을 생성하기 전에 반드시 존재해야 하는 것은 아닙니다. 그러나 이벤트 등록을 작성할 때 앱 또는 작업이 존재하지 않는 경우 등록 상태는 이용자가 존재하지 않음을 반영합니다. 등록이 준비 상태가 되기 전에 앱 또는 작업을 작성해야 하며 이 등록을 통해 이벤트를 수신할 수 있습니다.

콘솔에서 작업에 대한 Code Engine Kafka 이벤트 등록 작성

Kafka 이벤트 구독은 Kafka 의 이벤트 프로듀서(발신자)와 컨슈머(수신자) 간의 관계를 정의합니다.

시작하기 전에

• 사용할 Code Engine 프로젝트를 판별하고 이 프로젝트가 선택되었는지 확인하십시오. 프로젝트 작성 및 작업 을 참조하십시오.

콘솔에서 애플리케이션에 대한 ‘ Kafka ’ 이벤트 구독을 생성하려면 다음 단계를 따르십시오.

1. Code Engine 의 ‘프로젝트’ 페이지 에서 해당 프로젝트로 이동하세요.
2. 개요 페이지에서 이벤트 구독을 클릭하십시오.
3. 이벤트 구독 페이지에서 작성을 클릭하여 구독을 작성하십시오.
4. 이벤트 서브스크립션 작성 페이지에서 Event Streams / Kafka 타일을 선택하여 이벤트 유형을 지정하십시오.
5. 일반의 경우 Event Streams / Kafka 등록의 이름을 제공하십시오. 다음을 클릭하여 계속 진행하십시오.
6. 메시지 브로커 세부 정보 의 경우,
   1. 이 구독을 통해 이벤트로 수신되는 메시지가 포함된 메시지 큐에 대한 ‘ Kafka ’ 메시지 브로커 호스트를 지정하십시오. 브로커 호스트, 토픽 및 액세스 신임 정보에 대한 정보를 얻으려면 Event Streams 콘솔에서 서비스 인스턴스에 대한 서비스 신임 정보 세부사항을 보십시오. 예를 들어, myeventstream-key 서비스 인스턴스의 메시지 브로커 호스트에 대해 "broker-0-abcdabcdabcdabcd.kafka.svc01.us-south.eventstreams.cloud.ibm.com:9093", "broker-1-abcdabcdabcdabcd.kafka.svc01.us-south.eventstreams.cloud.ibm.com:9093" 를 지정하십시오.
   2. 구성 을 클릭하여 메시지 브로커에 대한 액세스를 구성하십시오. Code Engine 에서 Kafka 또는 Event Streams 인스턴스로 인증하려면 메시지 브로커 액세스 시크릿을 제공해야 합니다.
      • 새 시크릿을 작성하거나, 기존 시크릿을 선택하거나, 메시지 브로커에 액세스하는 데 신임 정보가 필요하지 않은 경우 None 를 선택할 수 있습니다.
      • 시크릿을 작성하려면 작성을 클릭하십시오. 시크릿의 이름과 username 및 password 의 값을 제공하십시오. username 및 password 의 값은 Kafka 또는 Event Streams 인스턴스에 대한 서비스 인증 정보의 값과 일치해야 합니다. 예를 들어, username 의 값은 Event Streams 서비스 인스턴스에서 서비스 인증 정보의 세부사항에 나열되는 user 의 값입니다. password 의 값은 Event Streams 서비스 인스턴스에서 서비스 인증 정보의 세부사항에 나열되는 apikey 의 값입니다.
      • 이 예제의 경우 이전에 작성된 기존 kafka-subscription-secret 시크릿을 사용하십시오.
   3. 메시지 큐에 대한 기존 토픽의 이름을 지정하십시오. 예를 들어, kafka-topic1입니다. 서비스 인스턴스의 기존 주제에 대한 정보를 얻으려면 Event Streams 콘솔에서 서비스 인스턴스로 이동하여 주제를 보십시오.
   4. (선택사항) 이용자 그룹을 지정하십시오. Kafka 메시지의 이용자는 이용자 그룹 으로 그룹화할 수 있습니다. 이용자 그룹을 사용 중인 경우 토픽 구성은 이용자 그룹의 이용자에 대한 메시지 플로우를 제어합니다. 이용자가 이용자 그룹에 추가되거나 이용자 그룹에서 제거될 때마다 해당 토픽의 메시지 플로우가 변경될 수 있습니다. 이 조치를 수행하면 기존 이용자가 더 이상 해당 토픽에서 메시지를 수신하지 않을 수 있습니다.
   5. 다음을 클릭하여 계속 진행하십시오.
7. 이벤트 수신자의 경우, 이벤트를 수신할 ‘ Code Engine ’ 작업을 지정하십시오. 정의된 작업 및 앱 목록에서 선택하거나 아직 작성되지 않은 작업 (또는 앱) 의 이름을 제공할 수 있습니다. 콘솔을 사용하여 이벤트 등록을 작성할 때 앱 또는 작업이 필요하지 않습니다. 그러나 구독이 작성될 때 구독의 상태는 이용자가 존재하지 않음을 반영합니다. 등록이 준비 상태가 되기 전에 작업 (또는 앱) 을 작성해야 하며 이 등록을 통해 이벤트를 수신할 수 있습니다. 이 예제의 경우, job 를 컴포넌트 유형으로 선택하고 icr.io/codeengine/codeengine 이미지를 컴포넌트로 참조하는 kafka-receiver-job 작업을 사용하여 이벤트를 수신하십시오. 해당 작업이 존재하지 않는 경우, 작업 이름을 입력하고 ‘ Kafka ’ 구독을 생성한 후 해당 작업을 생성하십시오. 애플리케이션의 경우 선택적으로 경로를 지정할 수 있습니다. 다음을 클릭하여 계속 진행하십시오.
8. 요약하자면, ‘ Kafka ’ 이벤트 구독 설정을 검토하고 필요한 경우 변경하십시오. 준비가 되면 ‘생성’을 클릭하여 ‘ Kafka ’ 구독을 생성하세요.

콘솔에서 수신 작업으로 이벤트 전송

kafka-receiver-job 작업을 참조하는 Kafka 이벤트 구독이 생성되었으므로, kafka-sender-app 를 사용하여 수신자 작업으로 메시지 이벤트를 전송하십시오.

1. 이벤트를 보려면 수신자 작업에 대한 로깅을 시작하여 콘솔에서 작업 로그 보기 를 수행하십시오.

2. (선택사항) 송신자 애플리케이션에 대한 로깅을 시작하여 콘솔에서 애플리케이션 로그를 보고 전송되는 이벤트에 대한 정보를 확인하십시오.

3. 로깅이 시작된 후 curl 으로 kafka-sender-app 애플리케이션을 호출하고 kafka-sender-app 의 공개 URL, 토픽 이름, 전송할 메시지 수를 지정합니다. 애플리케이션의 도메인 매핑 탭에서 이 애플리케이션의 공개 URL 를 얻을 수 있습니다. 예를 들면 다음과 같습니다.

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

값이 단일 문자열로 처리되도록 값을 따옴표로 묶어야 합니다.

Kafka 구독이 올바른 브로커, 토픽 및 액세스 시크릿으로 작성되고 해당 토픽 (예: kafka-sender-app) 에 대한 메시지를 생성하는 Kafka 작업이 있는 경우, Kafka 메시지 (예: kafka-receiver-job) 를 수신하는 Code Engine 작업에 대한 로그에서 이벤트를 볼 수 있습니다. Kafka 수신자 작업 (icr.io/codeengine/codeengine) 을 사용할 때 수신자 작업에 대한 로그에서 CE_DATA 를 검색하여 수신되는 메시지를 확인하십시오.

CLI를 사용하여 Kafka 이벤트를 수신하기 위한 Code Engine 작업 작성

시작하기 전에

• Code Engine CLI 환경을 설정하십시오.

• 프로젝트를 작성하고 작업하십시오.

1. Code Engine 작업 을 작성하여 Kafka 메시지의 이벤트 이용자 역할을 하고 Kafka 이벤트를 수신하십시오. 예를 들어, icr.io/codeengine/codeengine 이미지를 사용하는 kafka-receiver-job이라는 작업을 작성하십시오. 이 이미지는 codeengine.go 에서 가져온 것으로, IBM Cloud Code Engine GitHub 저장소의 샘플 에서 확인할 수 있습니다.

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

2. (선택사항) 이 작업을 작성한 후 job get 명령을 실행하여 이 작업에 대한 정보를 보십시오.

   ibmcloud ce job get -n kafka-receiver-job
   

CLI를 사용하여 작업에 대한 Code Engine Kafka 이벤트 등록 작성

CLI를 사용하여 이벤트의 ‘ Kafka ’ 프로듀서(발신자)와 컨슈머(수신자) 간의 관계를 정의하는 ‘ Kafka ’ 이벤트 구독을 생성할 수 있습니다.

1. ibmcloud ce sub kafka create 명령을 사용하여 Kafka 이벤트에 대한 Code Engine Kafka 이벤트 등록을 작성하십시오. 이전에 작성한 kafka-subscription-secret 시크릿을 사용하여 메시지 브로커에 액세스하십시오. Kafka 리소스에 대한 서비스 신임 정보를 기반으로 브로커 정보를 지정하십시오. 이 예의 경우, ibmcloud resource service-key myeventstream-key 명령의 출력에서 브로커 정보를 얻을 수 있습니다. 토픽의 각 브로커에 대해 --broker 옵션을 지정해야 합니다. --destination 옵션은 이벤트를 수신하는 Code Engine 자원을 지정합니다. 수신 작업에 대해 작업할 때 --destination-type 옵션도 지정하여 자원이 작업임을 지정해야 합니다. 이 옵션의 기본값은 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. Kafka 이벤트 구독에 대한 세부 정보를 표시합니다.

   ibmcloud ce sub kafka get -n mykafkasubscription-withjob
   

   출력 예

   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
   [...]
   

CLI를 사용하여 수신 작업에 이벤트 전송

kafka-receiver-job 애플리케이션을 참조하는 Kafka 이벤트 구독이 생성되었으므로, kafka-sender-app 을 사용하여 수신자 애플리케이션으로 메시지 이벤트를 전송하십시오.

1. 명령을 사용하여 대상 앱의 공개 URL ( kafka-sender-app )를 가져옵니다 ibmcloud ce app get 명령을 사용하여 앱의 URL 을 찾습니다.

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

   출력 예

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

2. Kafka 이벤트 생성자 앱, kafka-sender-app 를 실행하여 대상 Code Engine 작업에 이벤트를 전송하십시오. curl 를 사용하여 kafka-sender-app 애플리케이션을 호출하고 토픽에 대한 값 및 메시지 수를 지정하십시오. 명령의 출력을 사용하여 ibmcloud ce app get 명령의 출력을 사용하여 이벤트를 생성하는 앱의 공개 URL 를 찾습니다. 값이 단일 문자열로 처리되도록 값을 따옴표로 묶어야 합니다. 예를 들면 다음과 같습니다.

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

   예를 들면 다음과 같습니다.

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

3. 로그에서 이벤트를 봅니다. Kafka 이벤트 구독이 올바른 브로커, 토픽 및 액세스 시크릿을 사용하여 작성되고 해당 토픽 (예: kafka-sender-app) 에 대한 메시지를 생성하는 Kafka 앱이 있는 경우, Kafka 메시지 (예: kafka-receiver-job) 를 수신하는 대상 Code Engine 작업에 대한 로그에서 이벤트를 볼 수 있습니다. curl 를 사용하여 전송되는 각 메시지에 대해 동일한 수의 작업 실행이 Kafka 이벤트에 의해 트리거됩니다. 작업에 전송된 이벤트를 보려면 ibmcloud ce jobrun logs 명령을 사용하십시오.

   1. ibmcloud ce jobrun list 명령을 사용하여 kafka-receiver-job 작업에 대한 작업 실행을 나열하십시오.

       ibmcloud ce jobrun list --job kafka-receiver-job
       ```
   2. **`ibmcloud ce jobrun logs`** 명령을 사용하여 특정 작업 실행에 대한 로그를 확보하십시오.
   
   ```txt {: pre}
       ibmcloud ce jobrun logs -n kafka-receiver-job-abcde
       ```
       출력 예
   
       ```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
       ```
   Kafka 수신자 작업 (`icr.io/codeengine/codeengine`) 을 사용할 때 수신자 작업에 대한 로그에서 `CE_DATA` 를 검색하여 수신되는 메시지를 확인하십시오.
   
   작업 실행에 대한 로그 정보는 1시간 동안만 보관된다는 점에 유의하십시오. 앱 또는 작업에 대한 로그 보기에 대한 자세한 정보는 [로그 보기](/docs/codeengine?topic=codeengine-logging) 를 참조하십시오.