message

Type Members

1. class ByteBufferBackedInputStream extends InputStream

2. class ByteBufferMessageSet extends MessageSet with Logging

   A sequence of messages stored in a byte buffer

3. sealed trait CompressionCodec extends AnyRef

4. class InvalidMessageException extends RuntimeException

   Indicates that a message failed its checksum and is corrupt

5. class Message extends AnyRef

   A message.

6. case class MessageAndMetadata[K, V](topic: String, partition: Int, rawMessage: Message, offset: Long, keyDecoder: Decoder[K], valueDecoder: Decoder[V]) extends Product with Serializable

7. case class MessageAndOffset(message: Message, offset: Long) extends Product with Serializable

8. class MessageLengthException extends RuntimeException

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

9. abstract class MessageSet extends Iterable[MessageAndOffset]

   A set of messages with offsets.