kafka.message

ByteBufferMessageSet

class ByteBufferMessageSet extends MessageSet with Logging

A sequence of messages stored in a byte buffer

There are two ways to create a ByteBufferMessageSet

Option 1: From a ByteBuffer which already contains the serialized message set. Consumers will use this method.

Option 2: Give it a list of messages along with instructions relating to serialization format. Producers will use this method.

Linear Supertypes
Logging, MessageSet, Iterable[MessageAndOffset], IterableLike[MessageAndOffset, Iterable[MessageAndOffset]], Equals, GenIterable[MessageAndOffset], GenIterableLike[MessageAndOffset, Iterable[MessageAndOffset]], Traversable[MessageAndOffset], GenTraversable[MessageAndOffset], GenericTraversableTemplate[MessageAndOffset, Iterable], TraversableLike[MessageAndOffset, Iterable[MessageAndOffset]], GenTraversableLike[MessageAndOffset, Iterable[MessageAndOffset]], Parallelizable[MessageAndOffset, ParIterable[MessageAndOffset]], TraversableOnce[MessageAndOffset], GenTraversableOnce[MessageAndOffset], FilterMonadic[MessageAndOffset, Iterable[MessageAndOffset]], HasNewBuilder[MessageAndOffset, Iterable[kafka.message.MessageAndOffset] @scala.annotation.unchecked.uncheckedVariance], AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ByteBufferMessageSet
  2. Logging
  3. MessageSet
  4. Iterable
  5. IterableLike
  6. Equals
  7. GenIterable
  8. GenIterableLike
  9. Traversable
  10. GenTraversable
  11. GenericTraversableTemplate
  12. TraversableLike
  13. GenTraversableLike
  14. Parallelizable
  15. TraversableOnce
  16. GenTraversableOnce
  17. FilterMonadic
  18. HasNewBuilder
  19. AnyRef
  20. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ByteBufferMessageSet(messages: Message*)

  2. new ByteBufferMessageSet(compressionCodec: CompressionCodec, offsetCounter: AtomicLong, messages: Message*)

  3. new ByteBufferMessageSet(compressionCodec: CompressionCodec, messages: Message*)

  4. new ByteBufferMessageSet(buffer: ByteBuffer)

Type Members

  1. type Self = Iterable[MessageAndOffset]

    Attributes
    protected[this]
    Definition Classes
    TraversableLike

  2. class WithFilter extends FilterMonadic[A, Repr]

    Definition Classes
    TraversableLike

Value Members

  1. final def !=(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Definition Classes
    AnyRef → Any

  3. def ++[B >: MessageAndOffset, That](that: GenTraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That

    Definition Classes
    TraversableLike → GenTraversableLike

  4. def ++:[B >: MessageAndOffset, That](that: Traversable[B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That

    Definition Classes
    TraversableLike

  5. def ++:[B >: MessageAndOffset, That](that: TraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That

    Definition Classes
    TraversableLike

  6. def /:[B](z: B)(op: (B, MessageAndOffset) ⇒ B): B

    Definition Classes
    TraversableOnce → GenTraversableOnce

  7. def :\[B](z: B)(op: (MessageAndOffset, B) ⇒ B): B

    Definition Classes
    TraversableOnce → GenTraversableOnce

  8. final def ==(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  9. def addString(b: StringBuilder): StringBuilder

    Definition Classes
    TraversableOnce

  10. def addString(b: StringBuilder, sep: String): StringBuilder

    Definition Classes
    TraversableOnce

  11. def addString(b: StringBuilder, start: String, sep: String, end: String): StringBuilder

    Definition Classes
    TraversableOnce

  12. def aggregate[B](z: ⇒ B)(seqop: (B, MessageAndOffset) ⇒ B, combop: (B, B) ⇒ B): B

    Definition Classes
    TraversableOnce → GenTraversableOnce

  13. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  14. val buffer: ByteBuffer

  15. def canEqual(that: Any): Boolean

    Definition Classes
    IterableLike → Equals

  16. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  17. def collect[B, That](pf: PartialFunction[MessageAndOffset, B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That

    Definition Classes
    TraversableLike → GenTraversableLike

  18. def collectFirst[B](pf: PartialFunction[MessageAndOffset, B]): Option[B]

    Definition Classes
    TraversableOnce

  19. def companion: GenericCompanion[Iterable]

    Definition Classes
    Iterable → GenIterable → Traversable → GenTraversable → GenericTraversableTemplate

  20. def copyToArray[B >: MessageAndOffset](xs: Array[B], start: Int, len: Int): Unit

    Definition Classes
    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce

  21. def copyToArray[B >: MessageAndOffset](xs: Array[B]): Unit

    Definition Classes
    TraversableOnce → GenTraversableOnce

  22. def copyToArray[B >: MessageAndOffset](xs: Array[B], start: Int): Unit

    Definition Classes
    TraversableOnce → GenTraversableOnce

  23. def copyToBuffer[B >: MessageAndOffset](dest: Buffer[B]): Unit

    Definition Classes
    TraversableOnce

  24. def count(p: (MessageAndOffset) ⇒ Boolean): Int

    Definition Classes
    TraversableOnce → GenTraversableOnce

  25. def debug(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging

  26. def debug(e: ⇒ Throwable): Any

    Definition Classes
    Logging

  27. def debug(msg: ⇒ String): Unit

    Definition Classes
    Logging

  28. def drop(n: Int): Iterable[MessageAndOffset]

    Definition Classes
    IterableLike → TraversableLike → GenTraversableLike

  29. def dropRight(n: Int): Iterable[MessageAndOffset]

    Definition Classes
    IterableLike

  30. def dropWhile(p: (MessageAndOffset) ⇒ Boolean): Iterable[MessageAndOffset]

    Definition Classes
    TraversableLike → GenTraversableLike

  31. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  32. def equals(other: Any): Boolean

    Two message sets are equal if their respective byte buffers are equal

    Two message sets are equal if their respective byte buffers are equal

    Definition Classes
    ByteBufferMessageSet → Equals → AnyRef → Any

  33. def error(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging

  34. def error(e: ⇒ Throwable): Any

    Definition Classes
    Logging

  35. def error(msg: ⇒ String): Unit

    Definition Classes
    Logging

  36. def exists(p: (MessageAndOffset) ⇒ Boolean): Boolean

    Definition Classes
    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce

  37. def fatal(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging

  38. def fatal(e: ⇒ Throwable): Any

    Definition Classes
    Logging

  39. def fatal(msg: ⇒ String): Unit

    Definition Classes
    Logging

  40. def filter(p: (MessageAndOffset) ⇒ Boolean): Iterable[MessageAndOffset]

    Definition Classes
    TraversableLike → GenTraversableLike

  41. def filterNot(p: (MessageAndOffset) ⇒ Boolean): Iterable[MessageAndOffset]

    Definition Classes
    TraversableLike → GenTraversableLike

  42. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  43. def find(p: (MessageAndOffset) ⇒ Boolean): Option[MessageAndOffset]

    Definition Classes
    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce

  44. def flatMap[B, That](f: (MessageAndOffset) ⇒ GenTraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That

    Definition Classes
    TraversableLike → GenTraversableLike → FilterMonadic

  45. def flatten[B](implicit asTraversable: (MessageAndOffset) ⇒ GenTraversableOnce[B]): Iterable[B]

    Definition Classes
    GenericTraversableTemplate

  46. def fold[A1 >: MessageAndOffset](z: A1)(op: (A1, A1) ⇒ A1): A1

    Definition Classes
    TraversableOnce → GenTraversableOnce

  47. def foldLeft[B](z: B)(op: (B, MessageAndOffset) ⇒ B): B

    Definition Classes
    TraversableOnce → GenTraversableOnce

  48. def foldRight[B](z: B)(op: (MessageAndOffset, B) ⇒ B): B

    Definition Classes
    IterableLike → TraversableOnce → GenTraversableOnce

  49. def forall(p: (MessageAndOffset) ⇒ Boolean): Boolean

    Definition Classes
    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce

  50. def foreach[U](f: (MessageAndOffset) ⇒ U): Unit

    Definition Classes
    IterableLike → TraversableLike → GenTraversableLike → TraversableOnce → GenTraversableOnce → FilterMonadic

  51. def genericBuilder[B]: Builder[B, Iterable[B]]

    Definition Classes
    GenericTraversableTemplate

  52. def getBuffer: ByteBuffer

  53. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  54. def groupBy[K](f: (MessageAndOffset) ⇒ K): Map[K, Iterable[MessageAndOffset]]

    Definition Classes
    TraversableLike → GenTraversableLike

  55. def grouped(size: Int): Iterator[Iterable[MessageAndOffset]]

    Definition Classes
    IterableLike

  56. def hasDefiniteSize: Boolean

    Definition Classes
    TraversableLike → TraversableOnce → GenTraversableOnce

  57. def hashCode(): Int

    Definition Classes
    ByteBufferMessageSet → AnyRef → Any

  58. def head: MessageAndOffset

    Definition Classes
    IterableLike → TraversableLike → GenTraversableLike

  59. def headOption: Option[MessageAndOffset]

    Definition Classes
    TraversableLike → GenTraversableLike

  60. def info(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging

  61. def info(e: ⇒ Throwable): Any

    Definition Classes
    Logging

  62. def info(msg: ⇒ String): Unit

    Definition Classes
    Logging

  63. def init: Iterable[MessageAndOffset]

    Definition Classes
    TraversableLike → GenTraversableLike

  64. def inits: Iterator[Iterable[MessageAndOffset]]

    Definition Classes
    TraversableLike

  65. def isEmpty: Boolean

    Definition Classes
    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce

  66. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  67. final def isTraversableAgain: Boolean

    Definition Classes
    TraversableLike → GenTraversableLike → GenTraversableOnce

  68. def iterator: Iterator[MessageAndOffset]

    default iterator that iterates over decompressed messages

    default iterator that iterates over decompressed messages

    Definition Classes
    ByteBufferMessageSet → MessageSet → IterableLike → GenIterableLike

  69. def last: MessageAndOffset

    Definition Classes
    TraversableLike → GenTraversableLike

  70. def lastOption: Option[MessageAndOffset]

    Definition Classes
    TraversableLike → GenTraversableLike

  71. var logIdent: String

    Attributes
    protected
    Definition Classes
    Logging

  72. lazy val logger: Logger

    Definition Classes
    Logging

  73. val loggerName: String

    Definition Classes
    Logging

  74. def map[B, That](f: (MessageAndOffset) ⇒ B)(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That

    Definition Classes
    TraversableLike → GenTraversableLike → FilterMonadic

  75. def max[B >: MessageAndOffset](implicit cmp: Ordering[B]): MessageAndOffset

    Definition Classes
    TraversableOnce → GenTraversableOnce

  76. def maxBy[B](f: (MessageAndOffset) ⇒ B)(implicit cmp: Ordering[B]): MessageAndOffset

    Definition Classes
    TraversableOnce → GenTraversableOnce

  77. def min[B >: MessageAndOffset](implicit cmp: Ordering[B]): MessageAndOffset

    Definition Classes
    TraversableOnce → GenTraversableOnce

  78. def minBy[B](f: (MessageAndOffset) ⇒ B)(implicit cmp: Ordering[B]): MessageAndOffset

    Definition Classes
    TraversableOnce → GenTraversableOnce

  79. def mkString: String

    Definition Classes
    TraversableOnce → GenTraversableOnce

  80. def mkString(sep: String): String

    Definition Classes
    TraversableOnce → GenTraversableOnce

  81. def mkString(start: String, sep: String, end: String): String

    Definition Classes
    TraversableOnce → GenTraversableOnce

  82. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  83. def newBuilder: Builder[MessageAndOffset, Iterable[MessageAndOffset]]

    Attributes
    protected[this]
    Definition Classes
    GenericTraversableTemplate → HasNewBuilder

  84. def nonEmpty: Boolean

    Definition Classes
    TraversableOnce → GenTraversableOnce

  85. final def notify(): Unit

    Definition Classes
    AnyRef

  86. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  87. def par: ParIterable[MessageAndOffset]

    Definition Classes
    Parallelizable

  88. def parCombiner: Combiner[MessageAndOffset, ParIterable[MessageAndOffset]]

    Attributes
    protected[this]
    Definition Classes
    TraversableLike → Parallelizable

  89. def partition(p: (MessageAndOffset) ⇒ Boolean): (Iterable[MessageAndOffset], Iterable[MessageAndOffset])

    Definition Classes
    TraversableLike → GenTraversableLike

  90. def product[B >: MessageAndOffset](implicit num: Numeric[B]): B

    Definition Classes
    TraversableOnce → GenTraversableOnce

  91. def reduce[A1 >: MessageAndOffset](op: (A1, A1) ⇒ A1): A1

    Definition Classes
    TraversableOnce → GenTraversableOnce

  92. def reduceLeft[B >: MessageAndOffset](op: (B, MessageAndOffset) ⇒ B): B

    Definition Classes
    TraversableOnce

  93. def reduceLeftOption[B >: MessageAndOffset](op: (B, MessageAndOffset) ⇒ B): Option[B]

    Definition Classes
    TraversableOnce → GenTraversableOnce

  94. def reduceOption[A1 >: MessageAndOffset](op: (A1, A1) ⇒ A1): Option[A1]

    Definition Classes
    TraversableOnce → GenTraversableOnce

  95. def reduceRight[B >: MessageAndOffset](op: (MessageAndOffset, B) ⇒ B): B

    Definition Classes
    IterableLike → TraversableOnce → GenTraversableOnce

  96. def reduceRightOption[B >: MessageAndOffset](op: (MessageAndOffset, B) ⇒ B): Option[B]

    Definition Classes
    TraversableOnce → GenTraversableOnce

  97. def repr: Iterable[MessageAndOffset]

    Definition Classes
    TraversableLike → GenTraversableLike

  98. def reversed: List[MessageAndOffset]

    Attributes
    protected[this]
    Definition Classes
    TraversableOnce

  99. def sameElements[B >: MessageAndOffset](that: GenIterable[B]): Boolean

    Definition Classes
    IterableLike → GenIterableLike

  100. def scan[B >: MessageAndOffset, That](z: B)(op: (B, B) ⇒ B)(implicit cbf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That

    Definition Classes
    TraversableLike → GenTraversableLike

  101. def scanLeft[B, That](z: B)(op: (B, MessageAndOffset) ⇒ B)(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That

    Definition Classes
    TraversableLike → GenTraversableLike

  102. def scanRight[B, That](z: B)(op: (MessageAndOffset, B) ⇒ B)(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], B, That]): That

    Definition Classes
    TraversableLike → GenTraversableLike
    Annotations
    @migration
    Migration

    (Changed in version 2.9.0) The behavior of scanRight has changed. The previous behavior can be reproduced with scanRight.reverse.

  103. def seq: Iterable[MessageAndOffset]

    Definition Classes
    Iterable → GenIterable → Traversable → GenTraversable → Parallelizable → TraversableOnce → GenTraversableOnce

  104. def shallowIterator: Iterator[MessageAndOffset]

    iterator over compressed messages without decompressing

  105. def size: Int

    Definition Classes
    TraversableOnce → GenTraversableOnce

  106. def sizeInBytes: Int

    The total number of bytes in this message set, including any partial trailing messages

    The total number of bytes in this message set, including any partial trailing messages

    Definition Classes
    ByteBufferMessageSet → MessageSet

  107. def slice(from: Int, until: Int): Iterable[MessageAndOffset]

    Definition Classes
    IterableLike → TraversableLike → GenTraversableLike

  108. def sliding(size: Int, step: Int): Iterator[Iterable[MessageAndOffset]]

    Definition Classes
    IterableLike

  109. def sliding(size: Int): Iterator[Iterable[MessageAndOffset]]

    Definition Classes
    IterableLike

  110. def span(p: (MessageAndOffset) ⇒ Boolean): (Iterable[MessageAndOffset], Iterable[MessageAndOffset])

    Definition Classes
    TraversableLike → GenTraversableLike

  111. def splitAt(n: Int): (Iterable[MessageAndOffset], Iterable[MessageAndOffset])

    Definition Classes
    TraversableLike → GenTraversableLike

  112. def stringPrefix: String

    Definition Classes
    TraversableLike → GenTraversableLike

  113. def sum[B >: MessageAndOffset](implicit num: Numeric[B]): B

    Definition Classes
    TraversableOnce → GenTraversableOnce

  114. def swallow(action: ⇒ Unit): Unit

    Definition Classes
    Logging

  115. def swallowDebug(action: ⇒ Unit): Unit

    Definition Classes
    Logging

  116. def swallowError(action: ⇒ Unit): Unit

    Definition Classes
    Logging

  117. def swallowInfo(action: ⇒ Unit): Unit

    Definition Classes
    Logging

  118. def swallowTrace(action: ⇒ Unit): Unit

    Definition Classes
    Logging

  119. def swallowWarn(action: ⇒ Unit): Unit

    Definition Classes
    Logging

  120. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  121. def tail: Iterable[MessageAndOffset]

    Definition Classes
    TraversableLike → GenTraversableLike

  122. def tails: Iterator[Iterable[MessageAndOffset]]

    Definition Classes
    TraversableLike

  123. def take(n: Int): Iterable[MessageAndOffset]

    Definition Classes
    IterableLike → TraversableLike → GenTraversableLike

  124. def takeRight(n: Int): Iterable[MessageAndOffset]

    Definition Classes
    IterableLike

  125. def takeWhile(p: (MessageAndOffset) ⇒ Boolean): Iterable[MessageAndOffset]

    Definition Classes
    IterableLike → TraversableLike → GenTraversableLike

  126. def thisCollection: Iterable[MessageAndOffset]

    Attributes
    protected[this]
    Definition Classes
    IterableLike → TraversableLike

  127. def to[Col[_]](implicit cbf: CanBuildFrom[Nothing, MessageAndOffset, Col[MessageAndOffset]]): Col[MessageAndOffset]

    Definition Classes
    TraversableLike → TraversableOnce → GenTraversableOnce

  128. def toArray[B >: MessageAndOffset](implicit arg0: ClassTag[B]): Array[B]

    Definition Classes
    TraversableOnce → GenTraversableOnce

  129. def toBuffer[B >: MessageAndOffset]: Buffer[B]

    Definition Classes
    TraversableOnce → GenTraversableOnce

  130. def toCollection(repr: Iterable[MessageAndOffset]): Iterable[MessageAndOffset]

    Attributes
    protected[this]
    Definition Classes
    IterableLike → TraversableLike

  131. def toIndexedSeq: IndexedSeq[MessageAndOffset]

    Definition Classes
    TraversableOnce → GenTraversableOnce

  132. def toIterable: Iterable[MessageAndOffset]

    Definition Classes
    IterableLike → TraversableOnce → GenTraversableOnce

  133. def toIterator: Iterator[MessageAndOffset]

    Definition Classes
    IterableLike → TraversableLike → GenTraversableOnce
    Annotations
    @deprecatedOverriding( ... , "2.11.0" )

  134. def toList: List[MessageAndOffset]

    Definition Classes
    TraversableOnce → GenTraversableOnce

  135. def toMap[T, U](implicit ev: <:<[MessageAndOffset, (T, U)]): Map[T, U]

    Definition Classes
    TraversableOnce → GenTraversableOnce

  136. def toSeq: Seq[MessageAndOffset]

    Definition Classes
    TraversableOnce → GenTraversableOnce

  137. def toSet[B >: MessageAndOffset]: Set[B]

    Definition Classes
    TraversableOnce → GenTraversableOnce

  138. def toStream: Stream[MessageAndOffset]

    Definition Classes
    IterableLike → TraversableLike → GenTraversableOnce

  139. def toString(): String

    Print this message set's contents.

    Print this message set's contents. If the message set has more than 100 messages, just print the first 100.

    Definition Classes
    MessageSet → TraversableLike → AnyRef → Any

  140. def toTraversable: Traversable[MessageAndOffset]

    Definition Classes
    TraversableLike → TraversableOnce → GenTraversableOnce
    Annotations
    @deprecatedOverriding( ... , "2.11.0" )

  141. def toVector: Vector[MessageAndOffset]

    Definition Classes
    TraversableOnce → GenTraversableOnce

  142. def trace(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging

  143. def trace(e: ⇒ Throwable): Any

    Definition Classes
    Logging

  144. def trace(msg: ⇒ String): Unit

    Definition Classes
    Logging

  145. def transpose[B](implicit asTraversable: (MessageAndOffset) ⇒ GenTraversableOnce[B]): Iterable[Iterable[B]]

    Definition Classes
    GenericTraversableTemplate
    Annotations
    @migration
    Migration

    (Changed in version 2.9.0) transpose throws an IllegalArgumentException if collections are not uniformly sized.

  146. def unzip[A1, A2](implicit asPair: (MessageAndOffset) ⇒ (A1, A2)): (Iterable[A1], Iterable[A2])

    Definition Classes
    GenericTraversableTemplate

  147. def unzip3[A1, A2, A3](implicit asTriple: (MessageAndOffset) ⇒ (A1, A2, A3)): (Iterable[A1], Iterable[A2], Iterable[A3])

    Definition Classes
    GenericTraversableTemplate

  148. def validBytes: Int

    The total number of bytes in this message set not including any partial, trailing messages

  149. def view(from: Int, until: Int): IterableView[MessageAndOffset, Iterable[MessageAndOffset]]

    Definition Classes
    IterableLike → TraversableLike

  150. def view: IterableView[MessageAndOffset, Iterable[MessageAndOffset]]

    Definition Classes
    IterableLike → TraversableLike

  151. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  152. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  153. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  154. def warn(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes
    Logging

  155. def warn(e: ⇒ Throwable): Any

    Definition Classes
    Logging

  156. def warn(msg: ⇒ String): Unit

    Definition Classes
    Logging

  157. def withFilter(p: (MessageAndOffset) ⇒ Boolean): FilterMonadic[MessageAndOffset, Iterable[MessageAndOffset]]

    Definition Classes
    TraversableLike → FilterMonadic

  158. def writeTo(channel: GatheringByteChannel, offset: Long, size: Int): Int

    Write the messages in this set to the given channel

    Write the messages in this set to the given channel

    Definition Classes
    ByteBufferMessageSet → MessageSet

  159. def zip[A1 >: MessageAndOffset, B, That](that: GenIterable[B])(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], (A1, B), That]): That

    Definition Classes
    IterableLike → GenIterableLike

  160. def zipAll[B, A1 >: MessageAndOffset, That](that: GenIterable[B], thisElem: A1, thatElem: B)(implicit bf: CanBuildFrom[Iterable[MessageAndOffset], (A1, B), That]): That

    Definition Classes
    IterableLike → GenIterableLike

  161. def zipWithIndex[A1 >: MessageAndOffset, That](implicit bf: CanBuildFrom[Iterable[MessageAndOffset], (A1, Int), That]): That

    Definition Classes
    IterableLike → GenIterableLike

Inherited from Logging

Inherited from MessageSet

Inherited from Iterable[MessageAndOffset]

Inherited from IterableLike[MessageAndOffset, Iterable[MessageAndOffset]]

Inherited from Equals

Inherited from GenIterable[MessageAndOffset]

Inherited from GenIterableLike[MessageAndOffset, Iterable[MessageAndOffset]]

Inherited from Traversable[MessageAndOffset]

Inherited from GenTraversable[MessageAndOffset]

Inherited from GenericTraversableTemplate[MessageAndOffset, Iterable]

Inherited from TraversableLike[MessageAndOffset, Iterable[MessageAndOffset]]

Inherited from GenTraversableLike[MessageAndOffset, Iterable[MessageAndOffset]]

Inherited from Parallelizable[MessageAndOffset, ParIterable[MessageAndOffset]]

Inherited from TraversableOnce[MessageAndOffset]

Inherited from GenTraversableOnce[MessageAndOffset]

Inherited from FilterMonadic[MessageAndOffset, Iterable[MessageAndOffset]]

Inherited from HasNewBuilder[MessageAndOffset, Iterable[kafka.message.MessageAndOffset] @scala.annotation.unchecked.uncheckedVariance]

Inherited from AnyRef

Inherited from Any

Ungrouped