[−][src]Trait rdkafka::message::Message
The Message
trait provides access to the fields of a generic Kafka message.
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.
fn timestamp(&self) -> Timestamp
Returns the message timestamp for a consumed message if available.
fn headers(&self) -> Option<&Self::Headers>
Returns the headers of the message, if available.
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