kafka.javaapi.message

MessageSet

class MessageSet extends Iterable[MessageAndOffset]

A set of messages. A message set has a fixed serialized form, though the container for the bytes could be either in-memory or on disk. A The format of each message is as follows: 4 byte size containing an integer N N message bytes as described in the message class

Attributes
abstract
Linear Supertypes
Iterable[MessageAndOffset], AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. MessageSet
  2. Iterable
  3. AnyRef
  4. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MessageSet ()

Abstract Value Members

  1. def iterator (): Iterator[MessageAndOffset]

    Provides an iterator over the messages in this set

    Provides an iterator over the messages in this set

    Attributes
    abstract
    Definition Classes
    MessageSet → Iterable
  2. def sizeInBytes : Int

    Gives the total size of this message set in bytes

    Gives the total size of this message set in bytes

    Attributes
    abstract

Concrete Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any
  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  7. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  8. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  9. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  10. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  11. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  12. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  13. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  14. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  15. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  16. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  17. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  18. def toString (): String

    Definition Classes
    AnyRef → Any
  19. def validate (): Unit

    Validate the checksum of all the messages in the set.

    Validate the checksum of all the messages in the set. Throws an InvalidMessageException if the checksum doesn't match the payload for any message.

  20. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  21. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  22. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from Iterable[MessageAndOffset]

Inherited from AnyRef

Inherited from Any