Module rdkafka::message [−][src]
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. |