trait KafkaSubscription[F[_]] extends AnyRef
- Alphabetic
- By Inheritance
- KafkaSubscription
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def subscribe(regex: Regex): F[Unit]
Subscribes the consumer to the topics matching the specified
Regex
.Subscribes the consumer to the topics matching the specified
Regex
. Note that you have to use one of thesubscribe
functions before you can use any of the providedStream
s, or a NotSubscribedException will be raised in theStream
s.- regex
the regex to which matching topics should be subscribed
- abstract def subscribe[G[_]](topics: G[String])(implicit arg0: Reducible[G]): F[Unit]
Subscribes the consumer to the specified topics.
Subscribes the consumer to the specified topics. Note that you have to use one of the
subscribe
functions to subscribe to one or more topics before using any of the providedStream
s, or a NotSubscribedException will be raised in theStream
s.- topics
the topics to which the consumer should subscribe
- abstract def unsubscribe: F[Unit]
Unsubscribes the consumer from all topics and partitions assigned by
subscribe
orassign
.
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()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- 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()
- def subscribeTo(firstTopic: String, remainingTopics: String*): F[Unit]
Subscribes the consumer to the specified topics.
Subscribes the consumer to the specified topics. Note that you have to use one of the
subscribe
functions to subscribe to one or more topics before using any of the providedStream
s, or a NotSubscribedException will be raised in theStream
s. - 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()