Kafka 생산자 단계

  • 릴리스 버전: Xanadu
  • 업데이트 날짜 2024년 08월 01일
  • 소요 시간: 2분
  • Kafka 환경의 주제에 이벤트를 게시하는 작업을 생성합니다.

    역할 및 가용성

    Kafka 생산자 단계는 작업 단계입니다 워크플로우 스튜디오 . action_designer 역할을 가진 사용자는 하나 이상의 작업 단계로 사용자 지정 작업을 만들 수 있습니다.

    이 단계에는 구독이 필요합니다 스트리밍 연결 . 자세한 내용은 https://www.servicenow.com/products/automation-engine.html 문서를 참조하십시오.

    이 단계에는 Stream Connect Installer [com.glide.hub.stream_connect.installer] 플러그인이 ServiceNow 필요합니다.

    필드

    필드 설명
    주제

    메시지를 게시할 주제의 이름입니다. 주제는 동일한 유형의 메시지를 저장합니다. 예를 들어 결제라는 주제는 최근 결제에 대한 메시지를 저장할 수 있습니다.

    드롭다운 목록에서 주제를 선택합니다.

    메시지 메시지의 텍스트입니다.
    특정 파티션에 대한 키의 이름입니다. 주제는 분할할 수 있습니다. 동일한 키를 가진 메시지는 동일한 파티션에 저장됩니다. 예를 들어 키가 June인 결제 메시지는 모두 결제 주제의 동일한 파티션에 저장됩니다.
    헤더 이름-값 쌍으로 된 메시지의 헤더입니다. 이름 필드 모두에 값을 입력하거나 데이터 정제를 사용할 수 있습니다.
    완료 대기 플로우가 계속하기 전에 단계가 완료될 때까지 기다리도록 요구하는 옵션입니다.
    스키마 스키마 테이블에 대한 참조입니다. 목록에서 스키마를 선택합니다. 스키마에 대한 자세한 내용은 을 참조하십시오 Schema management in Stream Connect.
    주:
    메시지 필드에서 보내는 메시지는 선택한 스키마의 구조를 준수해야 합니다.
    이 단계가 실패할 경우 오류 평가로 이동하거나 다음 단계를 계속 실행하는 옵션입니다. 이 옵션은 단계 상태에 영향을 주지 않습니다. 다음 중 하나를 선택하십시오.
    • 작업 중지 및 오류 평가로 이동: 현재 단계에서 작업 실행을 중지하고 오류 평가로 이동합니다. 단계 상태 객체에는 단계에서 반환된 오류 정보가 포함되어 있습니다.
    • 작업을 중지하지 않고 다음 단계인 실패를 무시하고 다음 단계부터 작업을 계속 실행합니다. 단계 상태 객체에는 단계에서 반환된 오류 정보가 포함되어 있습니다. 작업이 계속 실행되는지 여부에 관계없이 작업 오류 평가가 실행됩니다.

    예제

    이 예시에서 단계는 인시던트 생성을 기록하는 메시지를 전송합니다. 메시지에는 인시던트 식별자, 설명 및 메시지 헤더가 포함됩니다. 메시지가 인시던트 주제로 전송되고 인시던트 식별자의 이름과 함께 파티션에 저장됩니다.

    Kafka 생산자 단계의 예.

    출력

    필드 설명 데이터 유형
    단계 상태 단계에 대한 런타임 상세 정보를 포함하는 객체 데이터 알약입니다. 작업의 각 단계는 단계 상태를 반환합니다. 객체
    단계 상태 > 코드 단계에서 오류가 발생했는지 여부를 나타내는 정수 데이터 알약입니다. 기본적으로 값 1은 단계에서 오류가 발생했음을 나타냅니다. 값이 0이면 단계가 성공적으로 실행되었음을 나타냅니다. 이러한 코드는 사용자 지정할 수 없습니다. 정수
    단계 상태 > 메시지 단계 또는 시스템 운영에 의해 생성된 오류 메시지를 포함하는 문자열 데이터 알약입니다. 이 메시지는 사용자 지정할 수 없습니다. 문자열