trait Control extends AnyRef
- Alphabetic
- By Inheritance
- Control
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def isShutdown: Future[Done]
Shutdown status.
Shutdown status. The
Futurewill be completed when the stage has been shut down and the underlyingKafkaConsumerhas been closed. Shutdown can be triggered from downstream cancellation, errors, or #shutdown. - abstract def metrics: Future[Map[MetricName, Metric]]
Exposes underlying consumer or producer metrics (as reported by underlying Kafka client library)
- abstract def shutdown(): Future[Done]
Shut down the consumer
Source.Shut down the consumer
Source.The actor backing the source will stay alive for
akka.kafka.consumer.stop-timeoutso that more commits from enqueued messages can be handled. The actor will wait for acknowledgements of the already sent offset commits from the Kafka broker before shutting down. - abstract def stop(): Future[Done]
Stop producing messages from the
Sourceand complete the stream.Stop producing messages from the
Sourceand complete the stream. The underlying Kafka consumer stays alive so that it can handle commits for the already enqueued messages. It does not unsubscribe from any topics/partitions as that could trigger a consumer group rebalance.Call #shutdown to close consumer.
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]) @native()
- def drainAndShutdown[S](streamCompletion: Future[S])(implicit ec: ExecutionContext): Future[S]
Stop producing messages from the
Source, wait for stream completion and shut down the consumerSourceso that all consumed messages reach the end of the stream.Stop producing messages from the
Source, wait for stream completion and shut down the consumerSourceso that all consumed messages reach the end of the stream. Failures in stream completion will be propagated, the source will be shut down anyway. - 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
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @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
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()