kafka
.
manager
.
actor
.
cluster
OffsetCacheActive
Related Doc:
package cluster
case class
OffsetCacheActive
(
curator:
CuratorFramework
,
kafkaAdminClient:
KafkaAdminClient
,
clusterContext:
ClusterContext
,
partitionLeaders: (
String
) ⇒
Option
[
List
[(
Int
,
Option
[
BrokerIdentity
])]]
,
topicDescriptions: (
String
,
Boolean
) ⇒
Option
[
TopicDescription
]
,
cacheTimeoutSecs:
Int
,
socketTimeoutMillis:
Int
,
kafkaVersion:
KafkaVersion
,
consumerProperties:
Option
[
Properties
]
,
getBrokerList: () ⇒
BrokerList
)
(
implicit
ec:
ExecutionContext
,
cf:
ClusterFeatures
)
extends
OffsetCache
with
Product
with
Serializable
Linear Supertypes
Serializable
,
Serializable
,
Product
,
Equals
,
OffsetCache
,
Logging
,
AnyRef
,
Any
Ordering
Alphabetic
By Inheritance
Inherited
OffsetCacheActive
Serializable
Serializable
Product
Equals
OffsetCache
Logging
AnyRef
Any
Hide All
Show All
Visibility
Public
All
Instance Constructors
new
OffsetCacheActive
(
curator:
CuratorFramework
,
kafkaAdminClient:
KafkaAdminClient
,
clusterContext:
ClusterContext
,
partitionLeaders: (
String
) ⇒
Option
[
List
[(
Int
,
Option
[
BrokerIdentity
])]]
,
topicDescriptions: (
String
,
Boolean
) ⇒
Option
[
TopicDescription
]
,
cacheTimeoutSecs:
Int
,
socketTimeoutMillis:
Int
,
kafkaVersion:
KafkaVersion
,
consumerProperties:
Option
[
Properties
]
,
getBrokerList: () ⇒
BrokerList
)
(
implicit
ec:
ExecutionContext
,
cf:
ClusterFeatures
)
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
val
cacheTimeoutSecs
:
Int
implicit
val
cf
:
ClusterFeatures
Definition Classes
OffsetCacheActive
→
OffsetCache
def
clone
()
:
AnyRef
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
...
)
val
clusterContext
:
ClusterContext
Definition Classes
OffsetCacheActive
→
OffsetCache
val
consumerProperties
:
Option
[
Properties
]
Definition Classes
OffsetCacheActive
→
OffsetCache
val
curator
:
CuratorFramework
def
debug
(
msg: ⇒
Any
,
t: ⇒
Throwable
)
:
Unit
Attributes
protected
Definition Classes
Logging
def
debug
(
msg: ⇒
Any
)
:
Unit
Attributes
protected
Definition Classes
Logging
implicit
val
ec
:
ExecutionContext
Attributes
protected[this]
Definition Classes
OffsetCacheActive
→
OffsetCache
final
def
eq
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
def
error
(
msg: ⇒
Any
,
t: ⇒
Throwable
)
:
Unit
Attributes
protected
Definition Classes
Logging
def
error
(
msg: ⇒
Any
)
:
Unit
Attributes
protected
Definition Classes
Logging
def
finalize
()
:
Unit
Attributes
protected[
java.lang
]
Definition Classes
AnyRef
Annotations
@throws
(
classOf[java.lang.Throwable]
)
val
getBrokerList
: () ⇒
BrokerList
Definition Classes
OffsetCacheActive
→
OffsetCache
def
getCacheTimeoutSecs
:
Int
Definition Classes
OffsetCacheActive
→
OffsetCache
final
def
getClass
()
:
Class
[_]
Definition Classes
AnyRef → Any
final
def
getConsumedTopicDescription
(
consumer:
String
,
topic:
String
,
interactive:
Boolean
,
consumerType:
ConsumerType
)
:
ConsumedTopicDescription
Definition Classes
OffsetCache
final
def
getConsumerDescription
(
consumer:
String
,
consumerType:
ConsumerType
)
:
ConsumerDescription
Definition Classes
OffsetCache
final
def
getConsumerList
:
ConsumerList
Definition Classes
OffsetCache
def
getConsumerTopics
(
consumer:
String
)
:
Set
[
String
]
Attributes
protected
Definition Classes
OffsetCache
def
getConsumerTopicsFromIds
(
consumer:
String
)
:
Set
[
String
]
Attributes
protected
Definition Classes
OffsetCacheActive
→
OffsetCache
def
getConsumerTopicsFromOffsets
(
consumer:
String
)
:
Set
[
String
]
Attributes
protected
Definition Classes
OffsetCacheActive
→
OffsetCache
def
getConsumerTopicsFromOwners
(
consumer:
String
)
:
Set
[
String
]
Attributes
protected
Definition Classes
OffsetCacheActive
→
OffsetCache
def
getKafkaManagedConsumerList
:
IndexedSeq
[
ConsumerNameAndType
]
Attributes
protected
Definition Classes
OffsetCache
def
getKafkaManagedConsumerTopics
(
consumer:
String
)
:
Set
[
String
]
Attributes
protected
Definition Classes
OffsetCache
def
getKafkaVersion
:
KafkaVersion
Definition Classes
OffsetCacheActive
→
OffsetCache
def
getSimpleConsumerSocketTimeoutMillis
:
Int
Definition Classes
OffsetCacheActive
→
OffsetCache
def
getTopicDescription
(
topic:
String
,
interactive:
Boolean
)
:
Option
[
TopicDescription
]
Attributes
protected
Definition Classes
OffsetCacheActive
→
OffsetCache
def
getTopicPartitionLeaders
(
topic:
String
)
:
Option
[
List
[(
Int
,
Option
[
BrokerIdentity
])]]
Attributes
protected
Definition Classes
OffsetCacheActive
→
OffsetCache
def
getTopicPartitionOffsets
(
topic:
String
,
interactive:
Boolean
)
:
Future
[
PartitionOffsetsCapture
]
Definition Classes
OffsetCache
def
getZKManagedConsumerList
:
IndexedSeq
[
ConsumerNameAndType
]
Attributes
protected
Definition Classes
OffsetCacheActive
→
OffsetCache
def
info
(
msg: ⇒
Any
,
t: ⇒
Throwable
)
:
Unit
Attributes
protected
Definition Classes
Logging
def
info
(
msg: ⇒
Any
)
:
Unit
Attributes
protected
Definition Classes
Logging
def
isDebugEnabled
:
Boolean
Attributes
protected
Definition Classes
Logging
def
isErrorEnabled
:
Boolean
Attributes
protected
Definition Classes
Logging
def
isInfoEnabled
:
Boolean
Attributes
protected
Definition Classes
Logging
final
def
isInstanceOf
[
T0
]
:
Boolean
Definition Classes
Any
def
isTraceEnabled
:
Boolean
Attributes
protected
Definition Classes
Logging
def
isWarnEnabled
:
Boolean
Attributes
protected
Definition Classes
Logging
val
kafkaAdminClient
:
KafkaAdminClient
Definition Classes
OffsetCacheActive
→
OffsetCache
val
kafkaVersion
:
KafkaVersion
final
def
lastUpdateMillis
:
Long
Definition Classes
OffsetCache
def
lastUpdateMillisZK
:
Long
Attributes
protected
Definition Classes
OffsetCacheActive
→
OffsetCache
val
loadOffsets
:
Boolean
Definition Classes
OffsetCacheActive
→
OffsetCache
def
logger
:
Logger
Attributes
protected
Definition Classes
Logging
def
loggerName
:
String
Attributes
protected
Definition Classes
Logging
final
def
ne
(
arg0:
AnyRef
)
:
Boolean
Definition Classes
AnyRef
final
def
notify
()
:
Unit
Definition Classes
AnyRef
final
def
notifyAll
()
:
Unit
Definition Classes
AnyRef
val
partitionLeaders
: (
String
) ⇒
Option
[
List
[(
Int
,
Option
[
BrokerIdentity
])]]
def
readConsumerOffsetByTopicPartition
(
consumer:
String
,
topic:
String
,
tpi:
Map
[
Int
,
TopicPartitionIdentity
]
)
:
Map
[
Int
,
Long
]
Attributes
protected
Definition Classes
OffsetCacheActive
→
OffsetCache
def
readConsumerOwnerByTopicPartition
(
consumer:
String
,
topic:
String
,
tpi:
Map
[
Int
,
TopicPartitionIdentity
]
)
:
Map
[
Int
,
String
]
Attributes
protected
Definition Classes
OffsetCacheActive
→
OffsetCache
def
readKafkaManagedConsumerOffsetByTopicPartition
(
consumer:
String
,
topic:
String
,
tpi:
Map
[
Int
,
TopicPartitionIdentity
]
)
:
Map
[
Int
,
Long
]
Attributes
protected
Definition Classes
OffsetCache
def
readKafkaManagedConsumerOwnerByTopicPartition
(
consumer:
String
,
topic:
String
,
tpi:
Map
[
Int
,
TopicPartitionIdentity
]
)
:
Map
[
Int
,
String
]
Attributes
protected
Definition Classes
OffsetCache
val
socketTimeoutMillis
:
Int
def
start
()
:
Unit
Definition Classes
OffsetCacheActive
→
OffsetCache
def
stop
()
:
Unit
Definition Classes
OffsetCacheActive
→
OffsetCache
final
def
synchronized
[
T0
]
(
arg0: ⇒
T0
)
:
T0
Definition Classes
AnyRef
val
topicDescriptions
: (
String
,
Boolean
) ⇒
Option
[
TopicDescription
]
def
trace
(
msg: ⇒
Any
,
t: ⇒
Throwable
)
:
Unit
Attributes
protected
Definition Classes
Logging
def
trace
(
msg: ⇒
Any
)
:
Unit
Attributes
protected
Definition Classes
Logging
final
def
wait
()
:
Unit
Definition Classes
AnyRef
Annotations
@throws
(
...
)
final
def
wait
(
arg0:
Long
,
arg1:
Int
)
:
Unit
Definition Classes
AnyRef
Annotations
@throws
(
...
)
final
def
wait
(
arg0:
Long
)
:
Unit
Definition Classes
AnyRef
Annotations
@throws
(
...
)
def
warn
(
msg: ⇒
Any
,
t: ⇒
Throwable
)
:
Unit
Attributes
protected
Definition Classes
Logging
def
warn
(
msg: ⇒
Any
)
:
Unit
Attributes
protected
Definition Classes
Logging
Inherited from
Serializable
Inherited from
Serializable
Inherited from
Product
Inherited from
Equals
Inherited from
OffsetCache
Inherited from
Logging
Inherited from
AnyRef
Inherited from
Any
Ungrouped