KafkaStream

Value Members

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

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

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

   

   Definition Classes

   TraversableLike → GenTraversableLike

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

   

   Definition Classes

   TraversableLike

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

   

   Definition Classes

   TraversableLike

6. def /:[B](z: B)(op: (B, MessageAndMetadata[K, V]) ⇒ B): B

   

   Definition Classes

   TraversableOnce → GenTraversableOnce

7. def :\[B](z: B)(op: (MessageAndMetadata[K, V], 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, MessageAndMetadata[K, V]) ⇒ B, combop: (B, B) ⇒ B): B

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

13. final def asInstanceOf[T0]: T0

    

    Definition Classes

    Any

14. def canEqual(that: Any): Boolean

    

    Definition Classes

    IterableLike → Equals

15. def clear(): Unit

    

    This method clears the queue being iterated during the consumer rebalancing.

    This method clears the queue being iterated during the consumer rebalancing. This is mainly to reduce the number of duplicates received by the consumer

16. val clientId: String

    

17. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

18. def collect[B, That](pf: PartialFunction[MessageAndMetadata[K, V], B])(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That

    

    Definition Classes

    TraversableLike → GenTraversableLike

19. def collectFirst[B](pf: PartialFunction[MessageAndMetadata[K, V], B]): Option[B]

    

    Definition Classes

    TraversableOnce

20. def companion: GenericCompanion[Iterable]

    

    Definition Classes

    Iterable → GenIterable → Traversable → GenTraversable → GenericTraversableTemplate

21. def copyToArray[B >: MessageAndMetadata[K, V]](xs: Array[B], start: Int, len: Int): Unit

    

    Definition Classes

    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce

22. def copyToArray[B >: MessageAndMetadata[K, V]](xs: Array[B]): Unit

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

23. def copyToArray[B >: MessageAndMetadata[K, V]](xs: Array[B], start: Int): Unit

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

24. def copyToBuffer[B >: MessageAndMetadata[K, V]](dest: Buffer[B]): Unit

    

    Definition Classes

    TraversableOnce

25. def count(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Int

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

26. def drop(n: Int): Iterable[MessageAndMetadata[K, V]]

    

    Definition Classes

    IterableLike → TraversableLike → GenTraversableLike

27. def dropRight(n: Int): Iterable[MessageAndMetadata[K, V]]

    

    Definition Classes

    IterableLike

28. def dropWhile(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Iterable[MessageAndMetadata[K, V]]

    

    Definition Classes

    TraversableLike → GenTraversableLike

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

    

    Definition Classes

    AnyRef

30. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

31. def exists(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Boolean

    

    Definition Classes

    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce

32. def filter(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Iterable[MessageAndMetadata[K, V]]

    

    Definition Classes

    TraversableLike → GenTraversableLike

33. def filterNot(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Iterable[MessageAndMetadata[K, V]]

    

    Definition Classes

    TraversableLike → GenTraversableLike

34. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

35. def find(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Option[MessageAndMetadata[K, V]]

    

    Definition Classes

    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce

36. def flatMap[B, That](f: (MessageAndMetadata[K, V]) ⇒ GenTraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That

    

    Definition Classes

    TraversableLike → GenTraversableLike → FilterMonadic

37. def flatten[B](implicit asTraversable: (MessageAndMetadata[K, V]) ⇒ GenTraversableOnce[B]): Iterable[B]

    

    Definition Classes

    GenericTraversableTemplate

38. def fold[A1 >: MessageAndMetadata[K, V]](z: A1)(op: (A1, A1) ⇒ A1): A1

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

39. def foldLeft[B](z: B)(op: (B, MessageAndMetadata[K, V]) ⇒ B): B

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

40. def foldRight[B](z: B)(op: (MessageAndMetadata[K, V], B) ⇒ B): B

    

    Definition Classes

    IterableLike → TraversableOnce → GenTraversableOnce

41. def forall(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Boolean

    

    Definition Classes

    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce

42. def foreach[U](f: (MessageAndMetadata[K, V]) ⇒ U): Unit

    

    Definition Classes

    IterableLike → TraversableLike → GenTraversableLike → TraversableOnce → GenTraversableOnce → FilterMonadic

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

    

    Definition Classes

    GenericTraversableTemplate

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

    

    Definition Classes

    AnyRef → Any

45. def groupBy[K](f: (MessageAndMetadata[K, V]) ⇒ K): Map[K, Iterable[MessageAndMetadata[K, V]]]

    

    Definition Classes

    TraversableLike → GenTraversableLike

46. def grouped(size: Int): Iterator[Iterable[MessageAndMetadata[K, V]]]

    

    Definition Classes

    IterableLike

47. def hasDefiniteSize: Boolean

    

    Definition Classes

    TraversableLike → TraversableOnce → GenTraversableOnce

48. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

49. def head: MessageAndMetadata[K, V]

    

    Definition Classes

    IterableLike → TraversableLike → GenTraversableLike

50. def headOption: Option[MessageAndMetadata[K, V]]

    

    Definition Classes

    TraversableLike → GenTraversableLike

51. def init: Iterable[MessageAndMetadata[K, V]]

    

    Definition Classes

    TraversableLike → GenTraversableLike

52. def inits: Iterator[Iterable[MessageAndMetadata[K, V]]]

    

    Definition Classes

    TraversableLike

53. def isEmpty: Boolean

    

    Definition Classes

    IterableLike → TraversableLike → TraversableOnce → GenTraversableOnce

54. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

55. final def isTraversableAgain: Boolean

    

    Definition Classes

    TraversableLike → GenTraversableLike → GenTraversableOnce

56. def iterator(): ConsumerIterator[K, V]

    

    Create an iterator over messages in the stream.

    Create an iterator over messages in the stream.

    Definition Classes

    KafkaStream → Iterable → IterableLike → GenIterableLike

57. def last: MessageAndMetadata[K, V]

    

    Definition Classes

    TraversableLike → GenTraversableLike

58. def lastOption: Option[MessageAndMetadata[K, V]]

    

    Definition Classes

    TraversableLike → GenTraversableLike

59. def map[B, That](f: (MessageAndMetadata[K, V]) ⇒ B)(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That

    

    Definition Classes

    TraversableLike → GenTraversableLike → FilterMonadic

60. def max[B >: MessageAndMetadata[K, V]](implicit cmp: Ordering[B]): MessageAndMetadata[K, V]

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

61. def maxBy[B](f: (MessageAndMetadata[K, V]) ⇒ B)(implicit cmp: Ordering[B]): MessageAndMetadata[K, V]

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

62. def min[B >: MessageAndMetadata[K, V]](implicit cmp: Ordering[B]): MessageAndMetadata[K, V]

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

63. def minBy[B](f: (MessageAndMetadata[K, V]) ⇒ B)(implicit cmp: Ordering[B]): MessageAndMetadata[K, V]

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

64. def mkString: String

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

65. def mkString(sep: String): String

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

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

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

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

    

    Definition Classes

    AnyRef

68. def newBuilder: Builder[MessageAndMetadata[K, V], Iterable[MessageAndMetadata[K, V]]]

    

    Attributes

    protected[this]

    Definition Classes

    GenericTraversableTemplate → HasNewBuilder

69. def nonEmpty: Boolean

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

70. final def notify(): Unit

    

    Definition Classes

    AnyRef

71. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

72. def par: ParIterable[MessageAndMetadata[K, V]]

    

    Definition Classes

    Parallelizable

73. def parCombiner: Combiner[MessageAndMetadata[K, V], ParIterable[MessageAndMetadata[K, V]]]

    

    Attributes

    protected[this]

    Definition Classes

    TraversableLike → Parallelizable

74. def partition(p: (MessageAndMetadata[K, V]) ⇒ Boolean): (Iterable[MessageAndMetadata[K, V]], Iterable[MessageAndMetadata[K, V]])

    

    Definition Classes

    TraversableLike → GenTraversableLike

75. def product[B >: MessageAndMetadata[K, V]](implicit num: Numeric[B]): B

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

76. def reduce[A1 >: MessageAndMetadata[K, V]](op: (A1, A1) ⇒ A1): A1

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

77. def reduceLeft[B >: MessageAndMetadata[K, V]](op: (B, MessageAndMetadata[K, V]) ⇒ B): B

    

    Definition Classes

    TraversableOnce

78. def reduceLeftOption[B >: MessageAndMetadata[K, V]](op: (B, MessageAndMetadata[K, V]) ⇒ B): Option[B]

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

79. def reduceOption[A1 >: MessageAndMetadata[K, V]](op: (A1, A1) ⇒ A1): Option[A1]

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

80. def reduceRight[B >: MessageAndMetadata[K, V]](op: (MessageAndMetadata[K, V], B) ⇒ B): B

    

    Definition Classes

    IterableLike → TraversableOnce → GenTraversableOnce

81. def reduceRightOption[B >: MessageAndMetadata[K, V]](op: (MessageAndMetadata[K, V], B) ⇒ B): Option[B]

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

82. def repr: Iterable[MessageAndMetadata[K, V]]

    

    Definition Classes

    TraversableLike → GenTraversableLike

83. def reversed: List[MessageAndMetadata[K, V]]

    

    Attributes

    protected[this]

    Definition Classes

    TraversableOnce

84. def sameElements[B >: MessageAndMetadata[K, V]](that: GenIterable[B]): Boolean

    

    Definition Classes

    IterableLike → GenIterableLike

85. def scan[B >: MessageAndMetadata[K, V], That](z: B)(op: (B, B) ⇒ B)(implicit cbf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That

    

    Definition Classes

    TraversableLike → GenTraversableLike

86. def scanLeft[B, That](z: B)(op: (B, MessageAndMetadata[K, V]) ⇒ B)(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That

    

    Definition Classes

    TraversableLike → GenTraversableLike

87. def scanRight[B, That](z: B)(op: (MessageAndMetadata[K, V], B) ⇒ B)(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], 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.

88. def seq: Iterable[MessageAndMetadata[K, V]]

    

    Definition Classes

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

89. def size: Int

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

90. def slice(from: Int, until: Int): Iterable[MessageAndMetadata[K, V]]

    

    Definition Classes

    IterableLike → TraversableLike → GenTraversableLike

91. def sliding(size: Int, step: Int): Iterator[Iterable[MessageAndMetadata[K, V]]]

    

    Definition Classes

    IterableLike

92. def sliding(size: Int): Iterator[Iterable[MessageAndMetadata[K, V]]]

    

    Definition Classes

    IterableLike

93. def span(p: (MessageAndMetadata[K, V]) ⇒ Boolean): (Iterable[MessageAndMetadata[K, V]], Iterable[MessageAndMetadata[K, V]])

    

    Definition Classes

    TraversableLike → GenTraversableLike

94. def splitAt(n: Int): (Iterable[MessageAndMetadata[K, V]], Iterable[MessageAndMetadata[K, V]])

    

    Definition Classes

    TraversableLike → GenTraversableLike

95. def stringPrefix: String

    

    Definition Classes

    TraversableLike → GenTraversableLike

96. def sum[B >: MessageAndMetadata[K, V]](implicit num: Numeric[B]): B

    

    Definition Classes

    TraversableOnce → GenTraversableOnce

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

    

    Definition Classes

    AnyRef

98. def tail: Iterable[MessageAndMetadata[K, V]]

    

    Definition Classes

    TraversableLike → GenTraversableLike

99. def tails: Iterator[Iterable[MessageAndMetadata[K, V]]]

    

    Definition Classes

    TraversableLike

100. def take(n: Int): Iterable[MessageAndMetadata[K, V]]

     

     Definition Classes

     IterableLike → TraversableLike → GenTraversableLike

101. def takeRight(n: Int): Iterable[MessageAndMetadata[K, V]]

     

     Definition Classes

     IterableLike

102. def takeWhile(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Iterable[MessageAndMetadata[K, V]]

     

     Definition Classes

     IterableLike → TraversableLike → GenTraversableLike

103. def thisCollection: Iterable[MessageAndMetadata[K, V]]

     

     Attributes

     protected[this]

     Definition Classes

     IterableLike → TraversableLike

104. def to[Col[_]](implicit cbf: CanBuildFrom[Nothing, MessageAndMetadata[K, V], Col[MessageAndMetadata[K, V]]]): Col[MessageAndMetadata[K, V]]

     

     Definition Classes

     TraversableLike → TraversableOnce → GenTraversableOnce

105. def toArray[B >: MessageAndMetadata[K, V]](implicit arg0: ClassTag[B]): Array[B]

     

     Definition Classes

     TraversableOnce → GenTraversableOnce

106. def toBuffer[B >: MessageAndMetadata[K, V]]: Buffer[B]

     

     Definition Classes

     TraversableOnce → GenTraversableOnce

107. def toCollection(repr: Iterable[MessageAndMetadata[K, V]]): Iterable[MessageAndMetadata[K, V]]

     

     Attributes

     protected[this]

     Definition Classes

     IterableLike → TraversableLike

108. def toIndexedSeq: IndexedSeq[MessageAndMetadata[K, V]]

     

     Definition Classes

     TraversableOnce → GenTraversableOnce

109. def toIterable: Iterable[MessageAndMetadata[K, V]]

     

     Definition Classes

     IterableLike → TraversableOnce → GenTraversableOnce

110. def toIterator: Iterator[MessageAndMetadata[K, V]]

     

     Definition Classes

     IterableLike → TraversableLike → GenTraversableOnce

     Annotations

     @deprecatedOverriding( ... , "2.11.0" )

111. def toList: List[MessageAndMetadata[K, V]]

     

     Definition Classes

     TraversableOnce → GenTraversableOnce

112. def toMap[T, U](implicit ev: <:<[MessageAndMetadata[K, V], (T, U)]): Map[T, U]

     

     Definition Classes

     TraversableOnce → GenTraversableOnce

113. def toSeq: Seq[MessageAndMetadata[K, V]]

     

     Definition Classes

     TraversableOnce → GenTraversableOnce

114. def toSet[B >: MessageAndMetadata[K, V]]: Set[B]

     

     Definition Classes

     TraversableOnce → GenTraversableOnce

115. def toStream: Stream[MessageAndMetadata[K, V]]

     

     Definition Classes

     IterableLike → TraversableLike → GenTraversableOnce

116. def toString(): String

     

     Definition Classes

     KafkaStream → TraversableLike → AnyRef → Any

117. def toTraversable: Traversable[MessageAndMetadata[K, V]]

     

     Definition Classes

     TraversableLike → TraversableOnce → GenTraversableOnce

     Annotations

     @deprecatedOverriding( ... , "2.11.0" )

118. def toVector: Vector[MessageAndMetadata[K, V]]

     

     Definition Classes

     TraversableOnce → GenTraversableOnce

119. def transpose[B](implicit asTraversable: (MessageAndMetadata[K, V]) ⇒ 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.

120. def unzip[A1, A2](implicit asPair: (MessageAndMetadata[K, V]) ⇒ (A1, A2)): (Iterable[A1], Iterable[A2])

     

     Definition Classes

     GenericTraversableTemplate

121. def unzip3[A1, A2, A3](implicit asTriple: (MessageAndMetadata[K, V]) ⇒ (A1, A2, A3)): (Iterable[A1], Iterable[A2], Iterable[A3])

     

     Definition Classes

     GenericTraversableTemplate

122. def view(from: Int, until: Int): IterableView[MessageAndMetadata[K, V], Iterable[MessageAndMetadata[K, V]]]

     

     Definition Classes

     IterableLike → TraversableLike

123. def view: IterableView[MessageAndMetadata[K, V], Iterable[MessageAndMetadata[K, V]]]

     

     Definition Classes

     IterableLike → TraversableLike

124. final def wait(): Unit

     

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

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

     

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

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

     

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

127. def withFilter(p: (MessageAndMetadata[K, V]) ⇒ Boolean): FilterMonadic[MessageAndMetadata[K, V], Iterable[MessageAndMetadata[K, V]]]

     

     Definition Classes

     TraversableLike → FilterMonadic

128. def zip[A1 >: MessageAndMetadata[K, V], B, That](that: GenIterable[B])(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], (A1, B), That]): That

     

     Definition Classes

     IterableLike → GenIterableLike

129. def zipAll[B, A1 >: MessageAndMetadata[K, V], That](that: GenIterable[B], thisElem: A1, thatElem: B)(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], (A1, B), That]): That

     

     Definition Classes

     IterableLike → GenIterableLike

130. def zipWithIndex[A1 >: MessageAndMetadata[K, V], That](implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], (A1, Int), That]): That

     

     Definition Classes

     IterableLike → GenIterableLike