Page Comparison

KafkaRecords are produced by Kafka Collections Agentscollections agents, and consumed by Kafka Forwarding Agentsforwarding agents.

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

A read-only field with 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

or will be forwarded to.

Automatically set.
`timestamp (long)`	The

time

collection or forwarding time which is set automatically.
`topic (string)`	The topic the message was collected from

/ is forwarded to. If there is only one Topic that can

or will 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.

Note!

When forwarding a message to Kafka, all fields are optional, except for topic and value.

Versions Compared