소비자 커넥터 구성 Apache Kafka

  • 릴리스 버전: Australia
  • 업데이트 날짜 2026년 03월 12일
  • 소요 시간: 6분

    • 커넥터에서 Apache Kafka 수집한 스트리밍 메시지에서 이벤트를 생성하도록 소비자 커넥터 인스턴스를 구성합니다.Apache Kafka

    시작하기 전에

    이벤트 관리 커넥터(sn_em_connector) 플러그인이 ServiceNow AI Platform 인스턴스에 설치되어 있는지 확인합니다.

    필요한 역할: evt_mgmt_admin

    프로시저

    1. 다음으로 이동 모두 > 이벤트 관리 > 통합 > 커넥터 인스턴스.
    2. 새로 만들기를 선택합니다.
    3. 양식에서 필드를 채웁니다.
      표 1. 커넥터 인스턴스 양식
      필드 값
      이름 Kafka Consumer 커넥터를 설명하는 고유한 이름입니다.
      설명 Kafka 소비자 이벤트 수집 인스턴스에서 사용할 설명입니다.
      커넥터 정의 필요한 커넥터 정의의 이름으로, 이 경우 Kafka Consumer입니다.
      호스트 IP 호스트 IP입니다.
      주:
      생성 프로세스를 완료하려면 이 필드에 값이 포함되어야 하므로 자리 표시자 1.1.1.1을 임시 값으로 입력해야 합니다.
      이벤트 수집의 마지막 실행 시간 이 필드는 마지막 런타임 값으로 자동 설정됩니다.
      마지막 이벤트 수집 상태 이 필드는 마지막 런타임 상태로 자동 설정됩니다.
      이벤트 수집 일정(초) 시스템에서 Kafka Consumer로부터 새 이벤트를 확인하는 빈도(초)입니다. 기본값은 60초입니다.
      마지막 오류 메시지 이 필드는 마지막 오류 메시지로 자동 설정됩니다.
    4. PLAINTEXT 또는 SASL_PLAINTEXT의 경우 자격 증명 필드에서 기본 인증 자격 증명을 생성합니다.
      SASL_PLAINTEXT 인증을 사용하여 새 Kafka 끌어오기 커넥터 인스턴스에 Kafka SSL 자격 증명 유형을 사용합니다. 5단계로 이동합니다.

      Kafka 서버의 sasl.enabled.mechanisms 또는 sasl.mechanism 매개변수 값이 PLAIN과 같지 않으면 Kafka SSL 자격 증명 유형을 사용합니다. 5단계로 이동합니다.

      1. 자격 증명 필드 옆에 있는 검색 아이콘 검색 아이콘을 선택합니다.
      2. 자격 증명 화면에서 새로 만들기를 선택합니다.
      3. 사용 가능한 자격 증명 목록에서 기본 인증 자격 증명을 선택합니다.
      4. 기본 인증 화면에서 자격 증명이 필요하지 않은 PLAINTEXT 인증 또는 자격 증명이 필요한 SASL_PLAINTEXT 인증에 대한 정보를 제공합니다.
        • PLAINTEXT 인증의 경우 이름 필드에 값을 입력하고 사용자 이름 및 암호 필드를 비워 둡니다.
        • SASL_PLAINTEXT 인증의 경우 이름 필드에 자격 증명의 이름을 지정합니다. 가급적 앞에 SASL을 붙입니다. 사용자 이름 및 암호 필드에 사용자 이름과 암호를 입력합니다.
      5. 제출을 선택합니다.
    5. SASL_PLAINTEXT, SSL 또는 SASL_SSL 인증 자격 증명의 경우 자격 증명 필드에서 Kafka SSL 자격 증명을 생성합니다.
      1. 자격 증명 필드 옆에 있는 검색 아이콘 검색 아이콘을 선택합니다.
      2. 자격 증명 화면에서 새로 만들기를 선택합니다.
      3. 사용 가능한 자격 증명 목록에서 Kafka SSL 자격 증명을 선택합니다.
      4. Kafka SSL 인증 화면에서 Kafka SSL 자격 증명 필드를 채웁니다.
        Kafka SSL 자격 증명 필드에 대한 설명은 다음 문서를 참조하십시오 .
        주:
        호스트 이름 검증 사용 안 함 필드를 지우면 추가 Kafka 소비자 속성 필드에 Kafka 서버 매개변수 값과 동일한 매개변수 값을 ssl.endpoint.identification.algorithm 입력합니다. 예: 
        ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1;
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username=<username> password=<password>;
sasl.enabled.mechanisms=PLAIN;ssl.endpoint.identification.algorithm=;
      5. 제출을 선택합니다.
    6. 양식 헤더를 마우스 오른쪽 버튼으로 클릭하고 저장을 선택합니다.
    7. 커넥터 인스턴스 값을 표시하는 테이블에서 Kafka 설정과 Kafka 주제에서 받은 메시지(JSON 페이로드)에 따라 채워진 커넥터 인스턴스 값을 확인합니다.

      필요한 경우 커넥터 인스턴스 값을 변경합니다.

      표 2. 커넥터 인스턴스 값 테이블
      필드 설명
      authentication_type

      Kafka Consumer 인증 유형입니다. 현재 지원되는 값은 다음과 같습니다.

      • PLAINTEXT(인증 없음)(기본값)

      • SASL_PLAINTEXT(기본 인증 - 사용자 이름 및 암호)
      bootstrap_servers

      Kafka 클러스터와의 연결을 설정하는 서버입니다. 이 필드의 값은 host1:port1, host2:port2 등의 쉼표로 구분된 형식이어야 합니다.

      이 필드는 필수입니다.
      consumer_group_name

      소비자 그룹 이름입니다.

      서로 다른 두 인스턴스에서 동일한 Kafka 주제가 사용되는 경우 두 인스턴스의 모든 이벤트가 캡처되도록 다른 소비자 그룹 이름을 사용합니다.

      이 필드는 필수입니다.
      time_of_event_field

      이벤트 시간이 포함된 JSON 페이로드/메시지의 필드 이름입니다.

      JSON 페이로드/메시지의 필드에 이벤트 시간이 포함되어 있는 경우 해당 값이 이 매개변수의 값이어야 합니다.

      시간 필드 값이 제공되지 않은 경우 인스턴스에서 받은 이벤트 ServiceNow 시간은 time_of_event로 설정됩니다.

      time_of_event 필드는 JSON 페이로드/메시지의 첫 번째 수준 필드여야 합니다. 중첩된 필드 이름은 허용되지 않습니다.
      시간대

      JSON 페이로드/메시지의 time_of_event 필드의 시간대입니다.

      time_of_event 필드가 비어 있으면 시간대 값이 사용되지 않습니다.

      예를 들어 페이로드/메시지의 time_of_event가 IST 시간대인 경우 값은 GMT+0530입니다.

      기본값: GMT
      date_format

      JSON 페이로드/메시지에 있는 time_of_event 필드의 date_time 형식입니다.

      시간 필드 값이 제공되지 않은 경우 인스턴스에서 받은 이벤트 시간에는 GMT 시간이 사용됩니다. time_of_event 필드가 비어 있으면 date_time 값이 사용되지 않습니다.

      기본값: yyyy-MM-dd HH:mm:sss
      디버그 디버그 메시지를 표시합니다. 기본값: false. 디버그 메시지를 보려면 true를 지정합니다.
      logPayloadForDebug 페이로드 관련 디버그 메시지를 표시합니다. 기본값: false. 페이로드 관련 디버그 메시지를 보려면 true를 지정합니다.
      주제

      메시지를 가져오는 Kafka 주제입니다.

      이 필드는 필수입니다.
    8. 커넥터용 MID 서버 섹션에서 실행 중이고 유효한 값을 MID 서버 지정합니다.
      주:
      여러 MID 서버. 첫 번째 서버가 다운되면 다음 MID 서버 서버가 사용됩니다. 사용할 MID 서버 수 없는 경우 다음 항목이 선택 MID 서버 됩니다 . 커넥터용 MID 서버 섹션에 상세 정보가 입력된 순서에 따라 정렬됩니다.

      지정 MID 서버하지 않으면 일치하는 IP 범위가 있는 사용 가능 항목 MID 서버 이 사용됩니다.

    9. 양식 헤더를 마우스 오른쪽 버튼으로 클릭하고 저장을 선택합니다.
    10. 와 Kafka Consumer 커넥터 간의 연결을 테스트합니다 MID 서버 .
      1. 커넥터 테스트를 선택합니다.
      2. 테스트 연결이 실패하면 자격 증명이 유효한지, 네트워크가 MID 서버 Kafka 브로커에서 연결되었는지 확인합니다.
        주:
        Kafka 주제 이름 확인은 테스트 커넥터 확인에서만 수행됩니다.
    11. 테스트가 성공적으로 완료되면 활성 확인란을 선택하여 커넥터 인스턴스를 활성화합니다.
    12. 업데이트 버튼을 선택합니다.

    다음에 수행할 작업

    커넥터가 생성되면 필드를 매핑해야 합니다. 자세한 내용은 Kafka 메시지 페이로드 속성을 경보 필드에 매핑 문서를 참조하십시오.