o

akka.kafka

Subscriptions

object Subscriptions

Source
Subscriptions.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Subscriptions
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def assignment(tps: Set[TopicPartition]): ManualSubscription

    JAVA API Manually assign given topics and partitions

  2. def assignment(tps: TopicPartition*): ManualSubscription

    JAVA API Manually assign given topics and partitions

    JAVA API Manually assign given topics and partitions

    Annotations
    @varargs()
  3. def assignment(tps: Set[TopicPartition]): ManualSubscription

    Manually assign given topics and partitions

  4. def assignmentOffsetsForTimes(tp: TopicPartition, timestamp: Long): ManualSubscription

    Manually assign given topics and partitions with timestamps

  5. def assignmentOffsetsForTimes(tps: Map[TopicPartition, Long]): ManualSubscription

    JAVA API Manually assign given topics and partitions with timestamps

  6. def assignmentOffsetsForTimes(tps: (TopicPartition, Long)*): ManualSubscription

    Manually assign given topics and partitions with timestamps

  7. def assignmentOffsetsForTimes(tps: Map[TopicPartition, Long]): ManualSubscription

    Manually assign given topics and partitions with timestamps

  8. def assignmentWithOffset(tp: TopicPartition, offset: Long): ManualSubscription

    Manually assign given topics and partitions with offsets

  9. def assignmentWithOffset(tps: Map[TopicPartition, Long]): ManualSubscription

    JAVA API Manually assign given topics and partitions with offsets

  10. def assignmentWithOffset(tps: (TopicPartition, Long)*): ManualSubscription

    Manually assign given topics and partitions with offsets

  11. def assignmentWithOffset(tps: Map[TopicPartition, Long]): ManualSubscription

    Manually assign given topics and partitions with offsets

  12. def topicPattern(pattern: String): AutoSubscription

    Creates subscription for given topics pattern

  13. def topics(ts: Set[String]): AutoSubscription

    JAVA API Creates subscription for given set of topics

  14. def topics(ts: String*): AutoSubscription

    JAVA API Creates subscription for given set of topics

    JAVA API Creates subscription for given set of topics

    Annotations
    @varargs()
  15. def topics(ts: Set[String]): AutoSubscription

    Creates subscription for given set of topics