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

Version 1 Current »

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 forwarding of the message.

headers (list<RecordHeader (Kafka)>)

An optional list of headers.

key (bytearray)

An optional field for the key.

offset (long)

A read-only field with the offset of the collected message.

outstandingRecordCnt (int)

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

partition (int)

The partition the message was collected from or will be forwarded to. Automatically set.

timestamp (long)

The collection or forwarding time which is set automatically.

topic (string)

The topic the message was collected from or will be forwarded to.

value (bytearray)

The contents of the message.

Note!

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

  • No labels