kafka

message

package message

Visibility
  1. Public
  2. All

Type Members

  1. sealed trait BrokerCompressionCodec extends AnyRef

  2. class BufferingOutputStream extends OutputStream

  3. class ByteBufferBackedInputStream extends InputStream

  4. class ByteBufferMessageSet extends MessageSet with Logging

    A sequence of messages stored in a byte buffer

  5. sealed trait CompressionCodec extends AnyRef

  6. class InvalidMessageException extends RuntimeException

    Indicates that a message failed its checksum and is corrupt

  7. class Message extends AnyRef

    A message.

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

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

  10. class MessageLengthException extends RuntimeException

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

  11. abstract class MessageSet extends Iterable[MessageAndOffset]

    A set of messages with offsets.

  12. class MessageWriter extends BufferingOutputStream

Value Members

  1. object BrokerCompressionCodec

  2. object ByteBufferMessageSet

  3. object CompressionCodec

  4. object CompressionFactory

  5. object DefaultCompressionCodec extends CompressionCodec with BrokerCompressionCodec with Product with Serializable

  6. object GZIPCompressionCodec extends CompressionCodec with BrokerCompressionCodec with Product with Serializable

  7. object LZ4CompressionCodec extends CompressionCodec with BrokerCompressionCodec with Product with Serializable

  8. object Message

    Constants related to messages

  9. object MessageSet

    Message set helper functions

  10. object NoCompressionCodec extends CompressionCodec with BrokerCompressionCodec with Product with Serializable

  11. object ProducerCompressionCodec extends BrokerCompressionCodec with Product with Serializable

  12. object SnappyCompressionCodec extends CompressionCodec with BrokerCompressionCodec with Product with Serializable

  13. object UncompressedCodec extends BrokerCompressionCodec with Product with Serializable

Ungrouped