2단계: 콘솔을 사용하여 Event Streams 인스턴스 프로비저닝

1. IBM Cloud 콘솔에 로그인하십시오.

2. 카탈로그에서 Event Streams 서비스 를 클릭하십시오.

3. 가격 플랜 선택 섹션에서 라이트 플랜, 표준 플랜또는 엔터프라이즈 플랜 을 선택하십시오.

4. 서비스의 이름을 입력하십시오. 기본값을 사용할 수 있습니다.

5. 작성을 클릭하십시오. Event Streams 의 리소스 목록 페이지가 열립니다.

6. 인스턴스가 작성되면 인스턴스 이름을 클릭하여 자세한 정보를 보십시오.

7. 선택사항입니다. 시작하기 튜토리얼 의 단계를 완료하여 샘플 스타터 앱을 실행할 수 있습니다.

2단계: CLI를 사용하여 Event Streams 인스턴스 프로비저닝

CLI를 처음 사용하는 경우에는 CLI 시작하기를 참조하십시오.

Event Streams 의 Standard Plan 인스턴스를 IBM Cloud CLI로 프로비저닝하려면 다음 단계를 완료하십시오

1. IBM Cloud CLI 시작하기의 단계를 완료하여 IBM Cloud CLI를 설치하십시오.

2. 다음 명령을 실행하여 IBM Cloud에 로그인하십시오.

   ibmcloud login -a cloud.ibm.com
   

3. Lite, 표준 또는 엔터프라이즈 플랜을 사용하여 Event Streams에서 IBM Cloud 인스턴스를 작성하십시오.

   다음 방법 중 하나를 선택하십시오.

   • 엔터프라이즈 플랜의 CLI에서 인스턴스를 작성하려면 다음 명령을 실행하십시오.

     ibmcloud resource service-instance-create <INSTANCE_NAME> messagehub enterprise-3nodes-2tb <REGION>
     

     엔터프라이즈 플랜은 각 클러스터에 자체 리소스를 할당하기 때문에 프로비저닝에 더 많은 시간이 소요되므로, 새로운 엔터프라이즈 인스턴스를 생성하는 데 최대 3시간이 걸릴 수 있습니다.

   • 표준 플랜의 CLI에서 인스턴스를 작성하려면 다음 명령을 실행하십시오.

     ibmcloud resource service-instance-create <INSTANCE_NAME> messagehub standard <REGION>
     

     기본 리소스가 이미 설정되어 있기 때문에 새로운 표준 플랜 인스턴스를 제공하는 것은 즉각적입니다.

2단계: 리소스 제어기 API를 사용하여 Event Streams 인스턴스 프로비저닝

인스턴스를 프로비저닝하기 위해 선호되는 방법은 CLI 를 사용하는 것입니다.

또는 자원 제어기 API를 사용할 수 있습니다. 먼저 액세스 토큰을 검색 한 후 액세스 토큰과 함께 자원 컨트롤러 API 명령을 실행하여 인스턴스를 작성 하십시오.

curl -X POST https://resource-controller.cloud.ibm.com/v2/resource_instances -H "Authorization: ${token}" -H "Content-Type: application/json" \
-d '{ "name": "JG-test-curl", "target": "us-south", "resource_group":"9eba3cff1b0540b9ab7fb93829911da0", "resource_plan_id": "ibm.message.hub.enterprise.3nodes.2tb", "parameters":{"service-endpoints":"public","throughput":"150"}}'

3단계: 콘솔을 사용하여 주제 작성 및 파티션 수 선택

주제를 작성할 때 수정할 수 있는 설정에 대한 지침은 주제 구성 을 참조하십시오.

1. 새로 프로비저닝된 인스턴스에서 왼쪽에 있는 메뉴를 사용하여 토픽 으로 이동하십시오.

2. 주제 작성 단추를 클릭하고 주제 이름을 입력하십시오. 다음을 클릭하십시오. 토픽 이름은 최대 200자로 제한됩니다.

3. 파티션 수를 선택하십시오.

   하나 이상의 파티션이 주제를 구성합니다. 파티션은 순서 지정된 메시지 목록입니다. 1개의 파티션으로 시작하기에 충분하지만 프로덕션 시스템에는 종종 더 많은 파티션이 있습니다.

   파티션은 브로커에 분산되어 토픽의 확장성을 향상시킵니다. 또한 이를 사용하여 소비자 그룹의 구성원 간에 메시지를 배포할 수도 있습니다.

   다음 을 클릭하십시오.

4. 메시지 보관 기간을 설정합니다. 이는 삭제되기 전에 메시지가 보존되는 기간입니다. 이용자가 이 시간 내에 메시지를 읽지 않으면 메시지가 누락됩니다. 메시지의 기본 보존 기간은 24시간입니다. 최소 1시간이며 최대 30일입니다. 이 값을 시간 배수로 지정하십시오.

   주제 만들기를 클릭합니다.

3단계: CLI를 사용하여 주제 작성 및 파티션 수 선택

주제를 작성할 때 수정할 수 있는 설정에 대한 지침은 주제 구성 을 참조하십시오.

다음 ibmcloud es topic-create 명령을 사용하여 선택한 수의 파티션으로 새 주제를 작성하십시오.

ibmcloud es topic-create [--name] TOPIC_NAME [--partitions PARTITIONS] [--config KEY=VALUE[;KEY=VALUE]* ]*

전제조건: 없음

명령 옵션:

--name 값, -n 값

토픽 이름입니다. 토픽 이름은 최대 200자로 제한됩니다.

--partitions 값, -p 값

토픽의 파티션 수를 설정합니다.

하나 이상의 파티션이 주제를 구성합니다. 파티션은 순서 지정된 메시지 목록입니다. 1개의 파티션으로 시작하기에 충분하지만 프로덕션 시스템에는 종종 더 많은 파티션이 있습니다.

파티션은 브로커에 분산되어 토픽의 확장성을 향상시킵니다. 또한 이를 사용하여 소비자 그룹의 구성원 간에 메시지를 배포할 수도 있습니다.

--config KEY=VALUE, -c KEY=VALUE(선택사항)

토픽의 구성 옵션을 KEY=VALUE 쌍으로 설정합니다.

여러 개의 --config 옵션을 지정할 수 있습니다. 각 '--config' 옵션은 세미콜론으로 구분된 지정 목록을 지정할 수 있습니다. 다음 목록은 유효한 구성 키를 보여줍니다

• cleanup.policy
• retention.ms
• retention.bytes
• segment.bytes
• segment.ms
• segment.index.bytes

retention.ms 키로 지정된 메시지의 기본 보존 기간은 24시간입니다. 최소 1시간이며 최대 30일입니다. 이 값을 시간 배수로 지정하십시오.

ibmcloud es topics [--filter FILTER] [--json]

ibmcloud es cluster [--json]

3단계: 관리 REST API를 사용하여 주제 작성 및 파티션 수 선택

Event Streams 는 주제를 작성하고 나열하는 데 사용할 수 있는 관리를 위한 REST API를 제공합니다.

/admin/topics 경로에 POST 요청을 발행하여 Kafka 토픽을 작성할 수 있습니다. 요청 본문에 JSON 문서가 포함되어야 합니다. 예를 들어, 다음과 같습니다.

{
    "name": "topicname",
    "partitions": 1,
    "configs": {
        "retentionMs": 86400000,
        "cleanupPolicy": "delete"
    }
}

JSON 문서에는 작성할 Kafka 토픽의 이름을 지정하는 name 속성이 포함되어야 합니다. 토픽 이름은 최대 200 characters.The JSON은 토픽에 지정할 파티션 수를 지정할 수도 있습니다 ( partitions 특성 사용). 파티션 수를 지정하지 않으면 단일 파티션으로 토픽이 작성됩니다.

하나 이상의 파티션이 주제를 구성합니다. 파티션은 순서 지정된 메시지 목록입니다. 1개의 파티션으로 시작하기에 충분하지만 프로덕션 시스템에는 종종 더 많은 파티션이 있습니다.

파티션은 브로커에 분산되어 토픽의 확장성을 향상시킵니다. 또한 이를 사용하여 소비자 그룹의 구성원 간에 메시지를 배포할 수도 있습니다.

요청 내에서 선택적 configs 오브젝트를 지정할 수도 있습니다. 이를 통해 retentionMs 특성을 지정할 수 있습니다. 이 특성은 Kafka 가 토픽에 발행된 메시지를 보유하는 기간 (밀리초) 을 제어합니다. 이 시간이 경과하면 메시지가 자동으로 삭제되어 여유 공간을 확보합니다. retentionMs 특성의 값을 전체 시간 (예: 3600000의 배수) 으로 지정해야 합니다. 메시지의 기본 보존 기간은 24시간입니다. 최소 1시간이며 최대 30일입니다.

주제를 작성할 때 수정할 수 있는 설정에 대한 지침은 주제 구성 을 참조하십시오.

HTTP 의 예상 상태 코드는 다음과 같습니다

• 202: 주제 작성 요청이 승인되었습니다.
• 400: 올바르지 않은 요청 JSON입니다.
• 403: 토픽을 작성할 수 있는 권한이 없습니다.
• 422: Semantically 유효하지 않은 요청입니다.

Kafka 주제를 생성하는 요청이 성공하면 HTTP 상태 코드 202(수락됨)가 반환됩니다. 작업이 실패하면 422(처리할 수 없는 엔티티)의 오류 상태 코드( HTTP )가 반환되고, 실패에 대한 추가 정보가 포함된 JSON 객체가 응답의 본문으로 반환됩니다.

curl -i -X POST -H 'Accept: application/json' -H 'Content-Type: application/json' -H 'Authorization: Bearer ${TOKEN}' --data '{ "name": "newtopic", "partitions": 1}' ${ADMIN_URL}/admin/topics

[
  {
    "name": "topic1",
    "partitions": 1,
    "retentionMs": 86400000,
    "cleanupPolicy": "delete"
  },
  { "name": "topic2",
    "partitions": 2,
    "retentionMs": 86400000,
    "cleanupPolicy": "delete"
  }
]

curl -i -X GET -H 'Accept: application/json' -H 'Authorization: Bearer ${TOKEN}' ${ADMIN_URL}/admin/topics

4단계: 콘솔을 사용하여 서비스 인증 정보 작성

Event Streams 인스턴스에 연결할 수 있도록 하려면 IBM Cloud 콘솔을 사용하여 서비스 키를 작성하십시오.

1. 리소스 목록에서 Event Streams 서비스를 찾으십시오.
2. 서비스 타일을 클릭하십시오.
3. 서비스 인증 정보를 클릭하십시오.
4. 새 인증 정보를 클릭하십시오.
5. 이름 및 역할과 같은 새 인증 정보에 대한 세부사항을 완료한 후 추가를 클릭하십시오. 새 인증 정보가 인증 정보 목록에 표시됩니다.
6. 새 신임 정보의 섹션을 펼쳐서 세부사항을 JSON 형식으로 표시하십시오.

4단계: CLI를 사용하여 서비스 인증 정보 작성

Event Streams 인스턴스에 연결할 수 있도록 IBM Cloud CLI를 사용하여 서비스 키를 작성하십시오.

1. 서비스 찾기:

   ibmcloud resource service-instances
   

2. 서비스 키 작성:

   ibmcloud resource service-key-create <key_name> <key_role> --instance-name <your_service_name>
   

3. 서비스 키 인쇄:

   ibmcloud resource service-key <key_name>
   

   단일 엔드포인트 세부사항 세트가 각 서비스 키에 포함되어 있습니다. 단일 네트워크 유형 ( IBM Cloud 공용 네트워크 (기본값) 또는 IBM Cloud 사설 네트워크) 에 연결되도록 구성된 서비스 인스턴스의 경우, 서비스 키에는 해당 네트워크 유형과 관련된 세부사항이 포함됩니다. 사설 및 공용 네트워크를 모두 지원하도록 구성된 인스턴스의 경우 공용 네트워크에 대한 세부사항이 리턴됩니다. 사설 네트워크에 대한 세부사항을 원하는 경우 --service-endpoint private 매개변수를 이전 service-key-create CLI 명령에 추가해야 합니다. 예를 들어, 다음과 같습니다.

   ibmcloud resource service-key-create <private-key-name> <role> --instance-name <instance-name> --service-endpoint private
   

4단계: CLI및 REST 생성자 API를 사용하여 서비스 신임 정보 작성

Event Streams 인스턴스에 연결하기 위해 지원되는 인증 메커니즘은 베어러 토큰을 사용합니다. IBM Cloud CLI를 사용하여 토큰을 얻으려면 먼저 IBM Cloud 에 로그인한 다음 다음 명령을 실행하십시오

ibmcloud iam oauth-tokens

이 토큰을 HTTP 요청의 권한 헤더에 Bearer<token> 양식으로 두십시오. API 키 또는 JWT 토큰이 모두 지원됩니다.

5단계: 콘솔을 사용하여 데이터 생성

콘솔을 사용하여 데이터를 생성할 수 없습니다. 명령행, REST Producer API 또는 Kafka API 를 사용하여 데이터를 생성할 수 있습니다.

그러나 시작하기 튜토리얼 의 콘솔에 대한 단계를 완료하여 샘플 스타터 앱을 실행하고 주제를 통해 플로우되는 메시지를 볼 수 있습니다.

5단계: 명령행을 사용하여 데이터 생성

Event Streams Kafka 콘솔 생성자 도구를 사용하여 데이터를 생성할 수 있습니다. 콘솔 도구는 Apache Kafka 다운로드에서 다운로드할 수 있는 Kafka 클라이언트 다운로드의 bin 디렉토리에 있습니다. 사용 가능한 최신의 안정적인 2진버전을 다운로드하는 것이 좋습니다. Kafka 클라이언트 버전은 서버의 Kafka 버전과 역호환 가능합니다.

브로커 목록 (BOOTSTRAP_ENDPOINTS 특성 사용) 및 SASL 신임 정보를 제공해야 합니다.

이 도구에 SASL 자격 증명을 제공하려면 다음 예제를 바탕으로 속성 파일을 만드십시오

    sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<user>" password="<api_key>";
    security.protocol=SASL_SSL
    sasl.mechanism=PLAIN
    ssl.protocol=TLSv1.2
    ssl.enabled.protocols=TLSv1.2
    ssl.endpoint.identification.algorithm=HTTPS

서비스 키의 <user> 필드를 사용자 이름으로 사용하고 서비스 키의 <api_key> 필드를 비밀번호로 사용하십시오. IBM Cloud 콘솔의 Event Streams 서비스 신임 정보 탭에서 이러한 값을 찾을 수 있습니다.

Event Streams 는 Java 클라이언트 에 대한 예제 producer.properties 및 consumer.properties 파일을 제공합니다.

속성 파일을 생성한 후, 다음과 같이 터미널에서 콘솔 프로듀서를 실행할 수 있습니다:

   kafka-console-producer.sh --broker-list BOOTSTRAP_ENDPOINTS --producer.config CONFIG_FILE --topic TOPIC_NAME

예제에 있는 다음 변수를 고유한 값으로 대체하십시오.

• IBM Cloud 콘솔에서 Event Streams 서비스 신임 정보 탭의 값이 있는 BOOTSTRAP_ENDPOINTS.
• CONFIG_FILE - 구성 파일 경로 포함

• 서비스 키의 <bootstrap_endpoints> 필드를 Kafka 애플리케이션의 bootstrap.servers 특성으로 사용하십시오.
• 서비스 키의 <user> 필드를 사용자 이름으로 사용하고 서비스 키의 <api_key> 필드를 비밀번호로 사용하십시오. 애플리케이션이 세부사항을 구문 분석하는지 확인하십시오.

ZooKeeper 에 액세스해야 하는 옵션을 제외한 이 도구의 다른 많은 옵션을 사용할 수 있습니다. 자세한 정보는 Event Streams 에서 Kafka 콘솔 도구 사용 의 내용을 참조하십시오.

5단계: REST 생성자 API를 사용하여 데이터 생성

REST Producer API의 v2 엔드포인트를 사용하여 text, binary, JSON, avro 유형의 메시지를 토픽으로 보냅니다. v2 엔드포인트를 사용하면 avro 데이터 유형에 대한 스키마를 지정하여 Event Streams 스키마 레지스트리를 사용할 수 있습니다.

• 헤더의 개념 선택사항입니까? 메시지 본문에 헤더가 표시됩니다. 이는 요청 또는 응답의 모든 것을 포함하는 데이터의 청크입니다. 헤더는 일반적으로 요청 행 또는 응답 행 뒤에 옵니다. 색상 값은 base64 입니다. 이를 수행하는 방법은 무엇입니까?

다음 코드는 curl을 사용하여 text 유형의 메시지를 보내는 예입니다

curl -v -X POST \
-H "Authorization: Bearer $token" -H "Content-Type: application/json" -H "Accept: application/json" \
-d '{
  "headers": [
    {
      "name": "colour",
      "value": "YmxhY2s="
    }
  ],
  "key": {
    "type": "text",
    "data": "Test Key"
  },
  "value": {
    "type": "text",
    "data": "Test Value"
  }
}' \
"$kafka_http_url/v2/topics/$topic_name/records"

자세한 정보는 Event Streams REST Producer v2 엔드포인트 API 참조를 참조하십시오.

6단계: 콘솔을 사용하여 데이터 이용

콘솔을 사용하여 데이터를 이용할 수 없습니다. 명령행 또는 Kafka API 를 사용하여 데이터를 이용할 수 있습니다.

그러나 시작하기 튜토리얼 의 단계를 완료하여 샘플 스타터 앱을 실행하고 주제를 통해 플로우되는 메시지를 볼 수 있습니다.

6단계: 명령행을 사용하여 데이터 이용

Event Streams Kafka 콘솔 이용자 도구를 사용하여 데이터를 이용할 수 있습니다.

콘솔 도구는 Kafka 클라이언트 다운로드의 bin 디렉토리에 있습니다.

브로커 및 SASL 인증 정보의 목록을 제공해야 합니다. 명령행을 사용하여 데이터 생성 에 설명된 대로 특성 파일을 작성한 후 다음과 같이 터미널에서 콘솔 이용자를 실행하십시오.

   kafka-console-consumer.sh --bootstrap-server BOOTSTRAP_ENDPOINTS --consumer.config CONFIG_FILE --topic TOPIC_NAME

예제에 있는 다음 변수를 고유한 값으로 대체하십시오.

• IBM Cloud 콘솔에서 Event Streams 서비스 신임 정보 탭의 값이 있는 BOOTSTRAP_ENDPOINTS.
• CONFIG_FILE - 구성 파일 경로 포함

ZooKeeper 에 액세스해야 하는 옵션을 제외한 이 도구의 다른 많은 옵션을 사용할 수 있습니다. 자세한 정보는 Event Streams 에서 Kafka 콘솔 도구 사용 의 내용을 참조하십시오.

6단계: API를 사용하여 데이터 이용

기본 Kafka 라이브러리를 사용하여 Kafka 의 데이터를 이용할 수 있지만 Event Streams API를 사용하여 데이터를 이용할 수 없습니다. 자세한 정보는 Kafka 이용자 API 를 참조하십시오.

또는 명령행 을 사용하십시오.

7단계: 콘솔을 사용하여 운영 가시성을 위해 IBM Cloud Monitoring 연결

IBM Cloud Monitoring 을 사용하여 애플리케이션, 서비스 및 플랫폼의 성능 및 상태에 대한 운영 가시성을 확보할 수 있습니다. IBM Cloud Monitoring 은 관리자, DevOps 팀 및 개발자 전체 스택 텔레메트리에 고급 기능을 제공하여 모니터링 및 문제점을 해결하고 경보를 정의하며 사용자 정의 대시보드를 디자인합니다.

Monitoring 와 Event Streams 의 사용 방법에 대한 자세한 내용은 다음을 참조하십시오

• 미터법 옵트 인
• 기본 메트릭 사용
• 향상된 메트릭 사용
• 사용 가능한 메트릭의 세부사항 보기
• 메트릭 비용 정보 이해

7단계: CLI 또는 명령행을 사용하여 운영 가시성을 위해 IBM Cloud Monitoring 연결

CLI 또는 명령행을 사용하여 IBM Cloud Monitoring 에 연결할 수 없습니다. 콘솔 을 사용하여 이 태스크를 완료하십시오.

7단계: API를 사용하여 운영 가시성을 위해 IBM Cloud Monitoring 연결

API를 사용하여 IBM Cloud Monitoring 에 연결할 수 없습니다. 콘솔 을 사용하여 이 태스크를 완료하십시오.

8단계: IBM Cloud® Activity Tracker 을 연결하여 서비스 활동 감사

IBM Cloud Activity Tracker 을 사용하면 회사 정책 및 산업 규정을 준수하기 위해 서비스 활동을 보고, 관리하고, 감사할 수 있습니다. Activity Tracker 는 IBM Cloud에서 서비스의 상태를 변경하는 사용자 시작 활동을 기록합니다. Activity Tracker 를 사용하여 Standard 및 Enterprise 요금제에서 사용자와 애플리케이션이 Event Streams 서비스와 어떻게 상호 작용하는지 추적하십시오.

Activity Tracker를 시작하고 실행하려면 Activity Tracker를 참조하십시오.

Activity Tracker의 경우 위치당 하나의 인스턴스만 포함할 수 있습니다. 이벤트를 보려면, 서비스 인스턴스를 사용할 수 있는 동일한 위치에서 Activity Tracker 서비스의 웹 UI에 액세스해야 합니다. 자세한 정보는 웹 UI 실행을 참조하십시오.

Event Streams에 특정한 이벤트에 대한 자세한 정보는 다음을 참조하십시오.

• 이벤트 확인 위치
• 토픽 이벤트
• 메시지 감사 이벤트
• 기타 이벤트

이벤트는 클라우드 감사 데이터 연합(CADF) 표준에 따라 포맷됩니다. 포함된 정보에 대한 자세한 정보는 CADF 표준 을 참조하십시오.

8단계: CLI 또는 명령행을 사용하여 IBM Cloud® Activity Tracker 에 연결하여 서비스 활동 감사

CLI 또는 명령행을 사용하여 Activity Tracker 에 연결할 수 없습니다. 콘솔 을 사용하여 이 태스크를 완료하십시오.

8단계: API를 사용하여 IBM Cloud® Activity Tracker 에 연결하여 서비스 활동 감사

API를 사용하여 Activity Tracker 에 연결할 수 없습니다. 콘솔 을 사용하여 이 태스크를 완료하십시오.