Struct rdkafka::message::OwnedMessage

pub struct OwnedMessage { /* fields omitted */ }

An OwnedMessage can be created from a BorrowedMessage using the BorrowedMessage::detach method. OwnedMessages don't hold any reference to the consumer and don't use any memory inside the consumer buffer.

Methods

impl OwnedMessage

pub fn new(
    payload: Option<Vec<u8>>,
    key: Option<Vec<u8>>,
    topic: String,
    timestamp: Timestamp,
    partition: i32,
    offset: i64,
    headers: Option<OwnedHeaders>
) -> OwnedMessage

Create a new message with the specified content. Mainly useful for writing tests.

Trait Implementations

impl Message for OwnedMessage

type Headers = OwnedHeaders

Represent the type of headers that this message contains.

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<&OwnedHeaders>

Returns the headers of the message, if available.

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

impl Debug for OwnedMessage

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.