kafka

message

package message

Visibility
  1. Public
  2. All

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.

Value Members

  1. object ByteBufferMessageSet

  2. object CompressionCodec

  3. object CompressionFactory

  4. object DefaultCompressionCodec extends CompressionCodec with Product with Serializable

  5. object GZIPCompressionCodec extends CompressionCodec with Product with Serializable

  6. object LZ4CompressionCodec extends CompressionCodec with Product with Serializable

  7. object Message

    Constants related to messages

  8. object MessageSet

    Message set helper functions

  9. object NoCompressionCodec extends CompressionCodec with Product with Serializable

  10. object SnappyCompressionCodec extends CompressionCodec with Product with Serializable

Ungrouped