Kafka 생산자 단계

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

    역할 및 가용성

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

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

    이 단계를 수행하려면 Stream Connect Installer [com.glide.hub.stream_connect.installer] 플러그인이 ServiceNow 필요합니다.

    필드

    필드 설명
    주제

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

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

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

    예제

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

    Kafka 생산자 단계 예.

    출력

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