Module rdkafka::message [] [src]

Store and manipulate Kafka messages.

Structs

BorrowedMessage

A zero-copy Kafka message.

OwnedMessage

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

Enums

Timestamp

Timestamp of a message

Traits

FromBytes

Given a reference to a byte array, returns a different view of the same data. No copy of the data should be performed.

Message

The Message trait provides access to the fields of a generic Kafka message.

ToBytes

Given some data, returns the byte representation of that data. No copy of the data should be performed.

Type Definitions

DeliveryResult

The result of a message production.