trait KafkaConsumerInterface extends AnyRef
- Alphabetic
- By Inheritance
- KafkaConsumerInterface
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- abstract type BatchedCursorContext
The type that represents the result of batching a
CursorContext - abstract type Control
The type that represents how to control the given stream, i.e.
The type that represents how to control the given stream, i.e. if you want to shut it down or add metrics
- abstract type CursorContext
The type of the context to pass around.
The type of the context to pass around. In context of a Kafka consumer, this typically holds offset data to be automatically committed
- abstract type MatCombineResult
The type that represents the result of the
combineparameter that is supplied to pekko.stream.scaladsl.Source.toMat
Abstract Value Members
- abstract def batchCursorContext(cursors: Iterable[CursorContext]): BatchedCursorContext
How to batch an immutable iterable of
CursorContextinto aBatchedCursorContextHow to batch an immutable iterable of
CursorContextinto aBatchedCursorContext- cursors
The cursors that need to be batched
- returns
A collection data structure that represents the batched cursors
- abstract def commitCursor: Sink[BatchedCursorContext, Future[Done]]
- returns
A
Sinkthat allows you to commit aCursorContextto Kafka to signify you have processed a message
- abstract def getSource: SourceWithContext[ReducedConsumerRecord, CursorContext, Control]
- returns
A
SourceWithContextthat returns a Kafka Stream which automatically handles committing of cursors
- abstract def matCombine: (Control, Future[Done]) => MatCombineResult
- returns
The result of this function gets directly passed into the
combineparameter of pekko.stream.scaladsl.Source.toMat
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])