Class AssignorConfiguration
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.assignment.AssignorConfiguration
-
public final class AssignorConfiguration extends Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
AssignorConfiguration.AssignmentConfigs
static interface
AssignorConfiguration.AssignmentListener
-
Constructor Summary
Constructors Constructor Description AssignorConfiguration(Map<String,?> configs)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Admin
adminClient()
AssignorConfiguration.AssignmentConfigs
assignmentConfigs()
AtomicInteger
assignmentErrorCode()
AssignorConfiguration.AssignmentListener
assignmentListener()
int
configuredMetadataVersion(int priorVersion)
CopartitionedTopicsEnforcer
copartitionedTopicsEnforcer()
InternalTopicManager
internalTopicManager()
String
logPrefix()
AtomicLong
nextScheduledRebalanceMs()
PartitionGrouper
partitionGrouper()
ConsumerPartitionAssignor.RebalanceProtocol
rebalanceProtocol()
StreamsMetadataState
streamsMetadataState()
TaskAssignor
taskAssignor()
TaskManager
taskManager()
org.apache.kafka.common.utils.Time
time()
String
userEndPoint()
-
-
-
Method Detail
-
assignmentErrorCode
public AtomicInteger assignmentErrorCode()
-
nextScheduledRebalanceMs
public AtomicLong nextScheduledRebalanceMs()
-
time
public org.apache.kafka.common.utils.Time time()
-
taskManager
public TaskManager taskManager()
-
streamsMetadataState
public StreamsMetadataState streamsMetadataState()
-
rebalanceProtocol
public ConsumerPartitionAssignor.RebalanceProtocol rebalanceProtocol()
-
logPrefix
public String logPrefix()
-
configuredMetadataVersion
public int configuredMetadataVersion(int priorVersion)
-
partitionGrouper
public PartitionGrouper partitionGrouper()
-
userEndPoint
public String userEndPoint()
-
adminClient
public Admin adminClient()
-
internalTopicManager
public InternalTopicManager internalTopicManager()
-
copartitionedTopicsEnforcer
public CopartitionedTopicsEnforcer copartitionedTopicsEnforcer()
-
assignmentConfigs
public AssignorConfiguration.AssignmentConfigs assignmentConfigs()
-
taskAssignor
public TaskAssignor taskAssignor()
-
assignmentListener
public AssignorConfiguration.AssignmentListener assignmentListener()
-
-