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.

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.