Skip to end of metadata
Go to start of metadata

You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 5 Next »

KafkaRecords are produced by Kafka Collections Agents, and consumed by Kafka Forwarding Agents.

Field

Description

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.

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

  • No labels