class MessageAndOffset

Header File: <libkafka_asio/message.h>

Namespace: libkafka_asio

Adds offset information to the Message class. Used for message consumption from Kafka.

MessageAndOffset (overload 1 of 2)

MessageAndOffset()

Creates an empty MessageAndOffset object. The offset information defaults to zero.

MessageAndOffset (overload 2 of 2)

MessageAndOffset(const Message& message, Int64 offset)

Creates a MessageAndOffset object by copying the given Message object (flat copy) and using the given offset information.

Member Functions

offset

Int64 offset() const

Returns the offset information.

set_offset

void set_offset(Int64 offset)

Sets the offset information.