#include <userver/kafka/message.hpp>
RAII wrapper for polled message data.
Message
instances must be destroyed before Consumer
stop Definition at line 21 of file message.hpp.
Public Member Functions | |
Message (Message &&)=default | |
const std::string & | GetTopic () const |
std::string_view | GetKey () const |
std::string_view | GetPayload () const |
std::optional< std::chrono::milliseconds > | GetTimestamp () const |
int | GetPartition () const |
std::int64_t | GetOffset () const |