Package

kafka.javaapi

message

Permalink

package message

Visibility
  1. Public
  2. All

Type Members

  1. class ByteBufferMessageSet extends MessageSet

    Permalink
  2. abstract class MessageSet extends Iterable[MessageAndOffset]

    Permalink

    A set of messages.

    A set of messages. A message set has a fixed serialized form, though the container for the bytes could be either in-memory or on disk. A The format of each message is as follows: 4 byte size containing an integer N N message bytes as described in the message class

Ungrouped