Trait rdkafka::message::Message[−][src]

pub trait Message {
    type Headers: Headers;
    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 headers(&self) -> Option<&Self::Headers>;

    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.

Associated Types

`type Headers: Headers`

Represent the type of headers that this message contains.

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

Implementors

impl<'a> Message for BorrowedMessage<'a> type Headers = BorrowedHeaders;
[src]
impl Message for OwnedMessage type Headers = OwnedHeaders;
[src]