5장. Kafka에 대한 Camel K 인증

1. OpenShift 클러스터의 웹 콘솔에 로그인합니다.
2. 통합을 만들려는 프로젝트를 만들거나 엽니다(예: my-camel-k-kafka ).
3. Camel K 설치에 설명된 대로 Camel K 및 Camel K CLI를 설치합니다. https://access.redhat.com/documentation/en-us/red_hat_integration/2023.q1/html-single/getting_started_with_camel_k#installing-camel-k

4. AMQ 스트림 Operator를 설치합니다.

   1. 모든 프로젝트에서 Operators > OperatorHub 를 선택합니다.
   2. 키워드로 필터링 필드에 AMQ Streams 를 입력합니다.

   3. Red Hat Integration - AMQ Streams 카드를 클릭한 다음 설치를 클릭합니다.

      Operator 설치 페이지가 열립니다.

   4. 기본값을 승인한 다음 설치를 클릭합니다.
5. Operators > 설치된 Operator 를 선택하여 Camel K 및 AMQ Streams Operator가 설치되었는지 확인합니다.

1. OpenShift 클러스터의 웹 콘솔에 로그인합니다.
2. 프로젝트를 선택한 다음 Red Hat Integration - AMQ Streams Operator를 설치한 프로젝트를 클릭합니다. 예를 들어 my-camel-k-kafka 프로젝트를 클릭합니다.
3. Operators > 설치된 Operators 를 선택한 다음 Red Hat Integration - AMQ Streams 를 클릭합니다.

4. Kafka 클러스터를 생성합니다.

   1. Kafka 에서 인스턴스 생성을 클릭합니다.
   2. 클러스터 이름을 입력합니다(예: kafka-test ).

   3. 다른 기본값을 승인한 다음 만들기 를 클릭합니다.

      Kafka 인스턴스를 생성하는 프로세스는 완료하는 데 몇 분이 걸릴 수 있습니다.

      상태가 준비되면 다음 단계를 계속합니다.

5. Kafka 주제를 생성합니다.

   1. Operators > 설치된 Operators 를 선택한 다음 Red Hat Integration - AMQ Streams 를 클릭합니다.
   2. Kafka 주제 에서 Kafka 주제 만들기 를 클릭합니다.
   3. 주제의 이름을 입력합니다(예: test-topic ).
   4. 다른 기본값을 승인한 다음 만들기 를 클릭합니다.

절차

1. 클러스터 관리자 계정으로 OpenShift 웹 콘솔에 로그인합니다.

2. Camel K 또는 Kamelets 애플리케이션에 대한 OpenShift 프로젝트를 생성합니다.

   1. 홈 > 프로젝트를 선택합니다.
   2. 프로젝트 만들기를 클릭합니다.
   3. 프로젝트 이름(예: my-camel-k-kafka )을 입력한 다음 생성을 클릭합니다.
3. rhoas CLI 시작하기에 설명된 대로 RHOAS CLI를 다운로드하여 설치합니다.
4. Camel K 설치에 설명된 대로 Camel K 및 Camel K CLI를 설치합니다. https://access.redhat.com/documentation/en-us/red_hat_integration/2023.q1/html-single/getting_started_with_camel_k#installing-camel-k
5. Red Hat Integration - Camel K operator가 설치되었는지 확인하려면 Operator > 설치된 Operator 를 클릭합니다.

1. 명령줄에서 OpenShift 클러스터에 로그인합니다.

2. 프로젝트를 엽니다. 예를 들면 다음과 같습니다.

   oc 프로젝트 my-camel-k-kafka

3. Camel K Operator가 프로젝트에 설치되어 있는지 확인합니다.

   oc get csv

   결과는 Red Hat Camel K operator를 나열하고 성공 단계에 있음을 나타냅니다.

4. Kafka 인스턴스를 준비하고 RHOAS에 연결합니다.

   1. 다음 명령을 사용하여 RHOAS CLI에 로그인합니다.

      rhoas login

   2. kafka-test 와 같이 kafka 인스턴스를 생성합니다.

      rhoas kafka create kafka-test

      Kafka 인스턴스를 생성하는 프로세스는 완료하는 데 몇 분이 걸릴 수 있습니다.

5. Kafka 인스턴스의 상태를 확인하려면 다음을 수행합니다.

   rhoas 상태

   웹 콘솔에서 상태를 볼 수도 있습니다.

   https://cloud.redhat.com/application-services/streams/kafkas/

   상태가 준비 되면 다음 단계를 계속합니다.

6. 새 Kafka 주제를 생성합니다.

   rhoas kafka topic create --name test-topic

7. Kafka 인스턴스(클러스터)를 Openshift Application Services 인스턴스와 연결합니다.

   rhoas 클러스터 연결

8. 인증 정보 토큰을 가져오려면 스크립트 지침을 따르십시오.

   출력은 다음과 유사합니다.

   Copy to Clipboard Toggle word wrap

   Token Secret "rh-cloud-services-accesstoken-cli" created successfully
   Service Account Secret "rh-cloud-services-service-account" created successfully
   KafkaConnection resource "kafka-test" has been created
   KafkaConnection successfully installed on your cluster.

절차

1. Kafka 브로커 URL (Bootstrap URL)을 가져옵니다.

   rhoas 상태

   이 명령은 다음과 유사한 출력을 반환합니다.

   Copy to Clipboard Toggle word wrap

     Kafka
     ---------------------------------------------------------------
     ID:                     1ptdfZRHmLKwqW6A3YKM2MawgDh
     Name:                   my-kafka
     Status:                 ready
     Bootstrap URL:        my-kafka--ptdfzrhmlkwqw-a-ykm-mawgdh.kafka.devshift.org:443

2. 사용자 이름과 암호를 가져오려면 다음 구문을 사용하여 서비스 계정을 생성합니다.

   rhoas service-account create --name "<account-name>" --file-format json

   참고

   서비스 계정을 생성할 때 자격 증명을 저장할 파일 형식 및 위치를 선택할 수 있습니다. 자세한 내용은 rhoas service-account create --help를 입력합니다.

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

   rhoas service-account create --name "my-service-acct" --file-format json

   서비스 계정이 생성되어 JSON 파일에 저장됩니다.

3. 서비스 계정 인증 정보를 확인하려면 credentials.json 파일을 확인합니다.

   cat credentials.json

   이 명령은 다음과 유사한 출력을 반환합니다.

   Copy to Clipboard Toggle word wrap

   {"clientID":"srvc-acct-eb575691-b94a-41f1-ab97-50ade0cd1094", "password":"facf3df1-3c8d-4253-aa87-8c95ca5e1225"}

4. Kakfa 주제로 또는에게 메시지를 보내거나 받을 수 있는 권한을 부여합니다. 다음 명령을 사용합니다. 여기서 clientID 는 credentials.json 파일에 제공된 값입니다(단계 3).

   Copy to Clipboard Toggle word wrap

   rhoas kafka acl grant-access --producer --consumer --service-account $CLIENT_ID --topic test-topic --group all

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

   Copy to Clipboard Toggle word wrap

   rhoas kafka acl grant-access --producer --consumer --service-account srvc-acct-eb575691-b94a-41f1-ab97-50ade0cd1094 --topic test-topic --group all

절차

1. application.properties 파일을 편집하고 Kafka 자격 증명을 추가합니다.

   application.properties 파일

   Copy to Clipboard Toggle word wrap

   camel.component.kafka.brokers = <YOUR-KAFKA-BOOTSTRAP-URL-HERE>
   camel.component.kafka.security-protocol = SASL_SSL
   camel.component.kafka.sasl-mechanism = PLAIN
   camel.component.kafka.sasl-jaas-config=org.apache.kafka.common.security.plain.PlainLoginModule required username='<YOUR-SERVICE-ACCOUNT-ID-HERE>' password='<YOUR-SERVICE-ACCOUNT-SECRET-HERE>';
   consumer.topic=<TOPIC-NAME>
   producer.topic=<TOPIC-NAME>

2. 다음 명령을 실행하여 application.properties 파일에 중요한 속성이 포함된 시크릿을 생성합니다.

   Copy to Clipboard Toggle word wrap

   oc create secret generic kafka-props --from-file application.properties

   Camel K 통합을 실행할 때 이 시크릿을 사용합니다.

절차

1. application-oauth.properties 파일을 편집하고 Kafka 자격 증명을 추가합니다.

   application-oauth.properties 파일

   Copy to Clipboard Toggle word wrap

   camel.component.kafka.brokers = <YOUR-KAFKA-BOOTSTRAP-URL-HERE>
   camel.component.kafka.security-protocol = SASL_SSL
   camel.component.kafka.sasl-mechanism = OAUTHBEARER
   camel.component.kafka.sasl-jaas-config = org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required \
   oauth.client.id='<YOUR-SERVICE-ACCOUNT-ID-HERE>' \
   oauth.client.secret='<YOUR-SERVICE-ACCOUNT-SECRET-HERE>' \
   oauth.token.endpoint.uri="https://identity.api.openshift.com/auth/realms/rhoas/protocol/openid-connect/token" ;
   camel.component.kafka.additional-properties[sasl.login.callback.handler.class]=io.strimzi.kafka.oauth.client.JaasClientOauthLoginCallbackHandler
   
   consumer.topic=<TOPIC-NAME>
   producer.topic=<TOPIC-NAME>

2. 다음 명령을 실행하여 application.properties 파일에 중요한 속성이 포함된 시크릿을 생성합니다.

   Copy to Clipboard Toggle word wrap

   oc create secret generic kafka-props --from-file application-oauth.properties

   Camel K 통합을 실행할 때 이 시크릿을 사용합니다.