@NotThreadSafe public class SbcContext extends Object
Constructor and Description |
---|
SbcContext(KafkaDataBalanceManager kdbm,
SbcEventQueue eventQueue,
BalancerResourceManager resourceManager,
kafka.server.KafkaConfig kafkaConfig,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
SbcEventQueue |
eventQueue() |
long |
generateEventId() |
kafka.server.KafkaConfig |
kafkaConfig() |
KafkaDataBalanceManager |
kafkaDataBalanceManager() |
BalancerResourceManager |
resourceManager() |
long |
taskHistoryRetentionMs()
Get the ApiPersistenceStore Task History Retention Period, which is available in the KafkaConfig.
|
org.apache.kafka.common.utils.Time |
time() |
public SbcContext(KafkaDataBalanceManager kdbm, SbcEventQueue eventQueue, BalancerResourceManager resourceManager, kafka.server.KafkaConfig kafkaConfig, org.apache.kafka.common.utils.Time time)
public KafkaDataBalanceManager kafkaDataBalanceManager()
public BalancerResourceManager resourceManager()
public SbcEventQueue eventQueue()
public org.apache.kafka.common.utils.Time time()
public long generateEventId()
public kafka.server.KafkaConfig kafkaConfig()
public long taskHistoryRetentionMs()