userver: kafka::Message Class Reference
Loading...
Searching...
No Matches
kafka::Message Class Referencefinal

#include <userver/kafka/message.hpp>

Detailed Description

RAII wrapper for polled message data.

Note
All 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
 

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