trait SubscriptionControl extends AnyRef
- Alphabetic
- By Inheritance
- SubscriptionControl
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def acknowledge(partition: Partition): Unit
Only with manual offsets.
Only with manual offsets.
Notify the subscription that user already process the partition and can be include in next [checkpoint] call.
- abstract def checkpoint(): Future[Done]
Only with manual offsets.
Only with manual offsets.
Persist in server the offset for all [acknowledge] partitions for current groupName
- abstract def getKafkaMetrics(metricNames: List[String] = List.empty[String]): Future[Map[String, String]]
Exposes Kafka consumer metrics.
Exposes Kafka consumer metrics.
A specific list of Kafka metric name Strings can be specified in metricNames. If there is no argument passed (or the list is empty), then all available Kafka consumer metrics will be retrieved. Only the metric name should be specified (without including the group), for example "time-between-poll-avg" or "records-consumed-rate".
In the Kafka consumer metrics returned, the
client-idvalue will be taken from theconsumerIdfield inConsumerSettings, which can be set to a specified value (if it is not set, then by default a random UUID will be assigned asclient-id). - abstract def shutdown(): Future[Done]
Shutdown the stream.
Shutdown the stream. It will wait for outstanding processes to finish before shutting down.
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]) @IntrinsicCandidate() @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
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @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])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)