RdKafka::MessageTimestamp Class Reference

Message timestamp object. More...

#include <rdkafkacpp.h>

Public Types
enum	MessageTimestampType {   MSG_TIMESTAMP_NOT_AVAILABLE,   MSG_TIMESTAMP_CREATE_TIME,   MSG_TIMESTAMP_LOG_APPEND_TIME }

Data Fields
MessageTimestampType	type
int64_t	timestamp

Detailed Description

Message timestamp object.

Represents the number of milliseconds since the epoch (UTC).

The MessageTimestampType dictates the timestamp type or origin.

Remarks

Requires Apache Kafka broker version >= 0.10.0

Member Enumeration Documentation

MessageTimestampType

enum RdKafka::MessageTimestamp::MessageTimestampType

Message timestamp type

Enumerator
MSG_TIMESTAMP_NOT_AVAILABLE	Timestamp not available
MSG_TIMESTAMP_CREATE_TIME	Message creation time (source)
MSG_TIMESTAMP_LOG_APPEND_TIME	Message log append time (broker)

Field Documentation

type

MessageTimestampType RdKafka::MessageTimestamp::type

Timestamp type

timestamp

int64_t RdKafka::MessageTimestamp::timestamp

Milliseconds since epoch (UTC).

---

The documentation for this class was generated from the following file:

• src-cpp/rdkafkacpp.h