Page Comparison

context (any)

An optional field for user defined information.

errorMessage (string)

Automatically populated if an error occurs during collection or 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 process. This value can be used as an indication for scaling.

partition (int)

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

<WHAT IF LEFT EMPTY?>

timestamp (long)

The time collection/forwarding time. Automatically set.

topic (string)

The topic the message was collected from / is forwarded to. If there is only one Topic that can be forwarded to, this field can be left empty. If a non-existing Topic is entered, the Topic will be created.

value (bytearray)

The contents of the message.