Trait

kafka.manager.actor.cluster

OffsetCache

Related Doc: package cluster

Permalink

trait OffsetCache extends Logging

Linear Supertypes
Logging, AnyRef, Any
Known Subclasses
OffsetCacheActive, OffsetCachePassive
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. OffsetCache
  2. Logging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. implicit abstract def cf: ClusterFeatures

    Permalink
    Attributes
    protected[this]

  2. abstract def clusterContext: ClusterContext

    Permalink

  3. abstract def consumerProperties: Option[Properties]

    Permalink

  4. implicit abstract def ec: ExecutionContext

    Permalink
    Attributes
    protected[this]

  5. abstract def getBrokerList: () ⇒ BrokerList

    Permalink
    Attributes
    protected

  6. abstract def getCacheTimeoutSecs: Int

    Permalink

  7. abstract def getConsumerTopicsFromIds(consumer: String): Set[String]

    Permalink
    Attributes
    protected

  8. abstract def getConsumerTopicsFromOffsets(consumer: String): Set[String]

    Permalink
    Attributes
    protected

  9. abstract def getConsumerTopicsFromOwners(consumer: String): Set[String]

    Permalink
    Attributes
    protected

  10. abstract def getKafkaVersion: KafkaVersion

    Permalink

  11. abstract def getSimpleConsumerSocketTimeoutMillis: Int

    Permalink

  12. abstract def getTopicDescription(topic: String, interactive: Boolean): Option[TopicDescription]

    Permalink
    Attributes
    protected

  13. abstract def getTopicPartitionLeaders(topic: String): Option[List[(Int, Option[BrokerIdentity])]]

    Permalink
    Attributes
    protected

  14. abstract def getZKManagedConsumerList: IndexedSeq[ConsumerNameAndType]

    Permalink
    Attributes
    protected

  15. abstract def kafkaAdminClient: KafkaAdminClient

    Permalink

  16. abstract def kafkaManagedOffsetCacheConfig: KafkaManagedOffsetCacheConfig

    Permalink

  17. abstract def lastUpdateMillisZK: Long

    Permalink
    Attributes
    protected

  18. abstract val loadOffsets: Boolean

    Permalink
    Attributes
    protected[this]

  19. abstract def readConsumerOffsetByTopicPartition(consumer: String, topic: String, tpi: Map[Int, TopicPartitionIdentity]): Map[Int, Long]

    Permalink
    Attributes
    protected

  20. abstract def readConsumerOwnerByTopicPartition(consumer: String, topic: String, tpi: Map[Int, TopicPartitionIdentity]): Map[Int, String]

    Permalink
    Attributes
    protected

Concrete Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  6. def debug(msg: ⇒ Any, t: ⇒ Throwable): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  7. def debug(msg: ⇒ Any): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  8. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  9. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  10. def error(msg: ⇒ Any, t: ⇒ Throwable): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  11. def error(msg: ⇒ Any): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  12. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  13. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any

  14. final def getConsumedTopicDescription(consumer: String, topic: String, interactive: Boolean, consumerType: ConsumerType): ConsumedTopicDescription

    Permalink

  15. final def getConsumerDescription(consumer: String, consumerType: ConsumerType): ConsumerDescription

    Permalink

  16. final def getConsumerList: ConsumerList

    Permalink

  17. def getConsumerTopics(consumer: String): Set[String]

    Permalink
    Attributes
    protected

  18. def getKafkaManagedConsumerList: IndexedSeq[ConsumerNameAndType]

    Permalink
    Attributes
    protected

  19. def getKafkaManagedConsumerTopics(consumer: String): Set[String]

    Permalink
    Attributes
    protected

  20. def getTopicPartitionOffsets(topic: String, interactive: Boolean): Future[PartitionOffsetsCapture]

    Permalink

  21. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  22. def info(msg: ⇒ Any, t: ⇒ Throwable): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  23. def info(msg: ⇒ Any): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  24. def isDebugEnabled: Boolean

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  25. def isErrorEnabled: Boolean

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  26. def isInfoEnabled: Boolean

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  27. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  28. def isTraceEnabled: Boolean

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  29. def isWarnEnabled: Boolean

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  30. final def lastUpdateMillis: Long

    Permalink

  31. def logger: Logger

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  32. def loggerName: String

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  33. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  34. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  35. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  36. def readKafkaManagedConsumerOffsetByTopicPartition(consumer: String, topic: String, tpi: Map[Int, TopicPartitionIdentity]): Map[Int, Long]

    Permalink
    Attributes
    protected

  37. def readKafkaManagedConsumerOwnerByTopicPartition(consumer: String, topic: String, tpi: Map[Int, TopicPartitionIdentity]): Map[Int, String]

    Permalink
    Attributes
    protected

  38. def start(): Unit

    Permalink

  39. def stop(): Unit

    Permalink

  40. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef

  41. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any

  42. def trace(msg: ⇒ Any, t: ⇒ Throwable): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  43. def trace(msg: ⇒ Any): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  44. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  45. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  46. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  47. def warn(msg: ⇒ Any, t: ⇒ Throwable): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  48. def warn(msg: ⇒ Any): Unit

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped