librdkafka
The Apache Kafka C/C++ client library
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

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: