kafka

message

package message

Visibility
  1. Public
  2. All

Type Members

  1. class ByteBufferBackedInputStream extends InputStream

  2. class ByteBufferMessageSet extends MessageSet

    A sequence of messages stored in a byte buffer

  3. trait CompressionCodec extends AnyRef

    attributes: sealed

  4. class FileMessageSet extends MessageSet

    An on-disk message set.

  5. class InvalidMessageException extends RuntimeException

    Indicates that a message failed its checksum and is corrupt

  6. class LogFlushStats extends LogFlushStatsMBean

  7. trait LogFlushStatsMBean extends AnyRef

  8. class Message extends AnyRef

    A message.

  9. class MessageAndOffset(message: Message, offset: Long) extends Product

    Represents message and offset of the next message.

  10. class MessageLengthException extends RuntimeException

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

  11. class MessageSet extends Iterable[MessageAndOffset]

    A set of messages.

Value Members

  1. object CompressionCodec extends AnyRef

  2. object CompressionUtils extends AnyRef

  3. object DefaultCompressionCodec extends CompressionCodec with Product

  4. object GZIPCompressionCodec extends CompressionCodec with Product

  5. object LogFlushStats extends AnyRef

  6. object Message extends AnyRef

    Message byte offsets

  7. object MessageSet extends AnyRef

    Message set helper functions

  8. object NoCompressionCodec extends CompressionCodec with Product