kafka

message

package message

Visibility
  1. Public
  2. All

Type Members

  1. class ByteBufferMessageSet extends MessageSet

    A sequence of messages stored in a byte buffer

  2. class FileMessageSet extends MessageSet

    An on-disk message set.

  3. class InvalidMessageException extends RuntimeException

    Indicates that a message failed its checksum and is corrupt

  4. class LogFlushStats extends LogFlushStatsMBean

  5. trait LogFlushStatsMBean extends AnyRef

  6. class Message extends AnyRef

    A message.

  7. class MessageLengthException extends RuntimeException

    Indicates the presense of a message that exceeds the maximum acceptable length (whatever that happens to be)

  8. class MessageSet extends Iterable[Message]

    A set of messages.

Value Members

  1. object LogFlushStats extends AnyRef

  2. object Message extends AnyRef

    Message byte offsets

  3. object MessageSet extends AnyRef

    Message set helper functions