Package org.apache.kafka.streams.processor.internals.assignment
-
Interface Summary Interface Description AssignorConfiguration.AssignmentListener TaskAssignor -
Class Summary Class Description AssignmentInfo AssignorConfiguration AssignorConfiguration.AssignmentConfigs ClientState CopartitionedTopicsEnforcer FallbackPriorTaskAssignor A special task assignor implementation to be used as a fallback in case the configured assignor couldn't be invoked.HighAvailabilityTaskAssignor StickyTaskAssignor StreamsAssignmentProtocolVersions SubscriptionInfo -
Enum Summary Enum Description AssignorError