Class Message

constructor

• new Message(
      value: Buffer,
      eventTime: Date,
      options?: sourceTransform.MessageOptions,
  ): sourceTransform.Message

  Create a new source transform output message.

  Parameters

  • value: Buffer

    The message payload as a Buffer

  • eventTime: Date

    The event time to assign to this message

  • Optionaloptions: sourceTransform.MessageOptions

    Optional keys, tags, and metadata

  Returns sourceTransform.Message

eventTime

Optionalkeys

Optionaltags

OptionaluserMetadata

value

StatictoDrop

• toDrop(eventTime: Date): sourceTransform.Message

  Create a drop message that will be discarded and not forwarded.

  Parameters

  • eventTime: Date

    The event time for the drop message

  Returns sourceTransform.Message

  A message marked for dropping