Stream Connect에서 메시지 및 Kafka 토픽 복제 만들기Create message and Kafka topic replications in Stream Connect

환경 Apache Kafka 과 ServiceNow.

시작하기 전에

• 필요한 역할: message_replication_admin
• 이 기능을 사용하려면 구독이 필요합니다. 자세한 내용은 Apache Kafka용 스트리밍 연결 사용 문서를 참조하십시오.
• 및 인스턴스 PKI 인증서 생성기가 Hermes 메시징 서비스 작동하는지 확인합니다.
  • Check the status of and connection to the Hermes Kafka cluster.
  • 인스턴스 PKI 섹션의 세 항목이 모두 작동하는지 확인하려면 다음을 Key Management Framework Health 선택합니다.
• 를 MID 서버구성하고 시작합니다. 자세한 내용은 Configuring MID Servers 문서를 참조하십시오. MID 서버 방화벽을 통해 엔드포인트에 액세스할 Hermes 수 있어야 합니다. 네트워크 관리자와 협력하여 다음 포트 범위가 열려 있는지 확인합니다.
  • 생산자: 4000–4050
  • 소비자1: 4100–4150
  • 소비자2: 4200–4250
• 스트림 커넥트 메시지 복제는 연결 및 자격 증명 별칭을 사용하여 로컬 Kafka에 연결합니다. Create a Connection & Credential alias의 연결 유형 이 Kafka입니다. 연결 및 자격 증명 별칭에는 Kafka Connection 및 Kafka SSL 자격 증명이 필요합니다.
• 스트림 커넥트 메시지 복제에는 ServiceNow 스트림 커넥트 설치 관리자 [com.glide.hub.stream_connect.installer] 플러그인이 필요합니다.

이 태스크 정보

이 페이지에서는 메시지 복제 레코드 및 연결된 Kafka 주제 복제 레코드를 만드는 방법을 보여줍니다.

메시지 복제 기록은 단일 Kafka 클러스터를 나타냅니다. 예를 들어 두 개의 Kafka 클러스터가 있는 경우 각 클러스터에 대해 하나씩 두 개의 서로 다른 메시지 복제 레코드를 만듭니다. 메시지 복제 기록은 해당 클러스터로 또는 해당 클러스터에서 복제되는 모든 주제에 대한 상위 기록입니다. 메시지 복제 기록은 메시지 복제 [sys_sc_message_replication] 테이블에 저장됩니다.

Kafka 주제 복제 기록은 단일 소스 주제에서 단일 대상 주제로의 복제를 지정합니다. 단일 소스 주제를 여러 대상에 복제할 수 없습니다. 각 대상에는 한 번만 복제할 수 있습니다. Kafka 주제 복제 기록은 Kafka 주제 복제 [sys_kafka_topic_replication] 테이블에 저장됩니다.

프로시저

1. 다음으로 이동 모두 > 통합 허브 > 스트림 커넥트 > 메시지 복제 을 클릭하고 새로 만들기를 선택합니다.
2. 메시지 복제 양식의 필드에 내용을 입력합니다.

   표 1. 메시지 복제 양식

   필드	설명
   이름	메시지 복제의 이름입니다.
   메시징 서비스 연결	연결할 메시징 서비스를 지정하는 연결 및 자격 증명 별칭입니다.
   상태	마지막으로 알려진 메시지 복제 상태입니다. 이 필드는 자동으로 설정됩니다.
   오류 메시지	마지막으로 알려진 메시지 복제 상태를 기반으로 하는 오류 메시지입니다. 이 필드는 자동으로 설정됩니다.
   애플리케이션	메시지 복제를 위한 애플리케이션 범위입니다. 이 필드는 자동으로 설정됩니다.
   활성	메시지 복제를 활성화하는 옵션입니다.

3. 저장을 선택합니다.
   양식을 저장하면 페이지 하단에 Kafka 주제 복제 탭이 나타납니다.
4. Kafka 주제 복제 탭에서 새로 만들기를 선택합니다.
5. Kafka 주제 복제 양식의 필드에 내용을 입력합니다.

   표 2. Kafka 주제 복제 양식

   필드	설명
   이름	토픽 복제의 이름. 이름은 다른 필드의 값에 따라 자동으로 생성됩니다. 이름을 생성하려면 방향, ServiceNow 주제 및 주제 이름 필드에 값을 입력한 다음 저장을 선택합니다. 방향이 ServiceNow로 향하는 경우, 이름의 형식은 토픽 이름 [복제 이름] -> ServiceNow 토픽 이름 [SN]입니다. 지시가 ServiceNow에서인 경우 이름의 형식은 ServiceNow 토픽 이름 [SN] -> 토픽 이름 [복제 이름]입니다.
   방향	주제 복제의 방향입니다. 대상 ServiceNow 는 로컬 Kafka 환경에서 로 주제를 복제합니다 ServiceNow. ServiceNow 에서 ServiceNow 주제를 로컬 Kafka 환경으로 복제합니다.
   ServiceNow 주제	Kafka 주제 [sys_kafka_topic] 테이블에 대한 참조입니다.
   복제	이 주제 복제를 관리하는 메시지 복제입니다.
   주제 이름	로컬 Kafka 환경에 있는 주제의 이름입니다.
   활성	주제 복제를 활성화하는 옵션입니다.
   상태	토픽 복제의 마지막으로 알려진 상태입니다. 이 필드는 자동으로 설정됩니다.
   오류 메시지	주제 복제의 마지막으로 알려진 상태를 기반으로 하는 오류 메시지입니다. 이 필드는 자동으로 설정됩니다.
   현재 업데이트 세트에서 추적	선택하면 주제 복제가 현재 업데이트 세트에 추가되므로 하위 프로덕션에서 프로덕션 인스턴스로 간편하게 승격할 수 있습니다. 이 필드를 추가하기 위해 양식을 구성해야 할 수 있습니다.

6. 제출을 선택합니다.
7. 1-6단계에 따라 모든 Kafka 클러스터와 주제에 대한 메시지 및 주제 복제를 생성합니다.

결과

모든 메시지 및 주제 복제 레코드를 만든 후에는 메시지가 복제되어야 합니다. 메시지 복제 기록의 상태 및 오류 메시지 필드에서 복제 작동 방식에 대한 일반적인 상태를 확인할 수 있습니다.

또한 각 개별 Kafka 주제 복제 기록의 상태 및 오류 메시지 필드에서 특정 주제 복제의 상태를 확인할 수 있습니다.

각 Kafka 주제 복제 기록에는 메시지 복제 통계라는 관련 목록도 있습니다. 복제가 실행되면 이 목록에는 각 주제 복제에 대해 60초마다 생성되는 메트릭 기록이 표시됩니다. 각 메트릭 기록에는 각 수집 간격에 복제된 메시지 수를 보여주는 메시지 수를 포함하여 주제 복제에 대한 정보가 있습니다.

다음에 수행할 작업

로컬 KafkaServiceNow에서 로 메시지를 복제하는 경우 스크립트를구성하여 메시지를 처리하거나 Kafka 메시지 트리거를 설정하여 플로우를 시작할 수 있습니다.변환 맵 소비자 구성

로컬 Kafka에서 메시지를 ServiceNow 복제하는 경우 in 워크플로우 스튜디오 또는 ProducerV2 API를 사용하여 Kafka Producer step 토픽 및 로컬 Kafka에 Hermes 메시지를 게시할 수 있습니다.