[−][src]Trait rdkafka::message::Message
A generic representation of a Kafka message.
Only read-only methods are provided by this trait, as the underlying storage might not allow modification.
Associated Types
Loading content...Required methods
fn key(&self) -> Option<&[u8]>
Returns the key of the message, or None
if there is no key.
fn payload(&self) -> Option<&[u8]>
Returns the payload of the message, or None
if there is no payload.
fn topic(&self) -> &str
Returns the source topic of the message.
fn partition(&self) -> i32
Returns the partition number where the message is stored.
fn offset(&self) -> i64
Returns the offset of the message within the partition.
fn timestamp(&self) -> Timestamp
Returns the message timestamp.
fn headers(&self) -> Option<&Self::Headers>
Returns the headers of the message, or None
if there are no headers.
Provided methods
fn payload_view<P: ?Sized + FromBytes>(&self) -> Option<Result<&P, P::Error>>
Converts the raw bytes of the payload to a reference of the specified type, that points to the same data inside the message and without performing any memory allocation.
fn key_view<K: ?Sized + FromBytes>(&self) -> Option<Result<&K, K::Error>>
Converts the raw bytes of the key to a reference of the specified type, that points to the same data inside the message and without performing any memory allocation.