[−][src]Module rdkafka::message
Store and manipulate Kafka messages.
Structs
BorrowedHeaders | Borrowed message headers |
BorrowedMessage | A zero-copy Kafka message. |
OwnedHeaders | Owned message headers |
OwnedMessage | 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. |
Enums
Timestamp | Timestamp of a message |
Traits
FromBytes | Given a reference to a byte array, returns a different view of the same data.
No allocation is performed, however the underlying data might be checked for
correctness (for example when converting to |
Headers | Message headers trait |
Message | The |
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. |