ByteBufferMessageSet
Related Docs:
object ByteBufferMessageSet
| package message
Two message sets are equal if their respective byte buffers are equal
Two message sets are equal if their respective byte buffers are equal
default iterator that iterates over decompressed messages
default iterator that iterates over decompressed messages
(Changed in version 2.9.0) The behavior of scanRight has changed. The previous behavior can be reproduced with scanRight.reverse.
iterator over compressed messages without decompressing
The total number of bytes in this message set, including any partial trailing messages
The total number of bytes in this message set, including any partial trailing messages
Print this message set's contents.
Print this message set's contents. If the message set has more than 100 messages, just print the first 100.
(Changed in version 2.9.0) transpose throws an IllegalArgumentException if collections are not uniformly sized.
The total number of bytes in this message set not including any partial, trailing messages
Write the messages in this set to the given channel
Write the messages in this set to the given channel
A sequence of messages stored in a byte buffer
There are two ways to create a ByteBufferMessageSet
Option 1: From a ByteBuffer which already contains the serialized message set. Consumers will use this method.
Option 2: Give it a list of messages along with instructions relating to serialization format. Producers will use this method.