#include <userver/kafka/message.hpp>
Wrapper for polled message data access.
Definition at line 21 of file message.hpp.
Public Member Functions | |
Message (Message &&) noexcept | |
Message & | operator= (Message &&) noexcept=delete |
Message (const Message &)=delete | |
Message & | operator= (const Message &)=delete |
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 |