Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Field

Description

context (any)

An optional field for user defined information.

errorMessage (string)

Automatically populated if an error occurs during forwarding of the message.

headers (list<RecordHeader (Kafka)>)

An optional list of headers.

key (bytearray)

An optional field for the key.

offset (long)

The offset of the collected message. A read only field.

outstandingRecordCnt (int)

A read only field indicating how many records are left to send.

partition (int)

The partition the message was collected from / is forwarded to. Automatically set.

timestamp (long)

The collection/forwarding time. Automatically set.

topic (string)

The topic the message was collected from / is forwarded to.

value (bytearray)

The contents of the message.

...