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