Trait rdkafka::message::Message
[−]
[src]
pub trait Message {
fn key(&self) -> Option<&[u8]>;
fn payload(&self) -> Option<&[u8]>;
fn topic(&self) -> &str;
fn partition(&self) -> i32;
fn offset(&self) -> i64;
fn timestamp(&self) -> Timestamp;
fn payload_view<P: ?Sized + FromBytes>(
&self
) -> Option<Result<&P, P::Error>> { ... }
fn key_view<K: ?Sized + FromBytes>(&self) -> Option<Result<&K, K::Error>> { ... }
}The Message trait provides access to the fields of a generic Kafka message.
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.
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
Implementors
impl<'a> Message for BorrowedMessage<'a>impl Message for OwnedMessage