test_class.declarator: state = new SubscriptionState(OffsetResetStrategy.EARLIEST)
test_class.modifier: private final
test_class.original_string: private final SubscriptionState state = new SubscriptionState(OffsetResetStrategy.EARLIEST);
test_class.type: SubscriptionState
test_class.var_name: state
test_class.declarator: topic = "test"
test_class.modifier: private final
test_class.original_string: private final String topic = "test";
test_class.type: String
test_class.var_name: topic
test_class.declarator: topic1 = "test1"
test_class.modifier: private final
test_class.original_string: private final String topic1 = "test1";
test_class.type: String
test_class.var_name: topic1
test_class.declarator: tp0 = new TopicPartition("test", 0)
test_class.modifier: private final
test_class.original_string: private final TopicPartition tp0 = new TopicPartition("test", 0);
test_class.type: TopicPartition
test_class.var_name: tp0
test_class.declarator: tp1 = new TopicPartition("test", 1)
test_class.modifier: private final
test_class.original_string: private final TopicPartition tp1 = new TopicPartition("test", 1);
test_class.type: TopicPartition
test_class.var_name: tp1
test_class.declarator: rebalanceListener = new MockRebalanceListener()
test_class.modifier: private final
test_class.original_string: private final MockRebalanceListener rebalanceListener = new MockRebalanceListener();
test_class.type: MockRebalanceListener
test_class.var_name: rebalanceListener
test_class.file: clients/src/test/java/org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java
test_class.identifier: SubscriptionStateTest
test_case.body: @Test(expected = IllegalStateException.class)
      public void cantChangePositionForNonAssignedPartition() {
          state.position(tp0, 1);
      }
test_case.class_method_signature: SubscriptionStateTest.cantChangePositionForNonAssignedPartition()
test_case.full_signature: @Test(expected = IllegalStateException.class) public void cantChangePositionForNonAssignedPartition()
test_case.identifier: cantChangePositionForNonAssignedPartition
test_case.invocations: position
test_case.modifiers: @Test(expected = IllegalStateException.class) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void cantChangePositionForNonAssignedPartition()
focal_class.declarator: subscriptionType
focal_class.modifier: private
focal_class.original_string: private SubscriptionType subscriptionType;
focal_class.type: SubscriptionType
focal_class.var_name: subscriptionType
focal_class.declarator: subscribedPattern
focal_class.modifier: private
focal_class.original_string: private Pattern subscribedPattern;
focal_class.type: Pattern
focal_class.var_name: subscribedPattern
focal_class.declarator: subscription
focal_class.modifier: private final
focal_class.original_string: private final Set<String> subscription;
focal_class.type: Set<String>
focal_class.var_name: subscription
focal_class.declarator: userAssignment
focal_class.modifier: private final
focal_class.original_string: private final Set<TopicPartition> userAssignment;
focal_class.type: Set<TopicPartition>
focal_class.var_name: userAssignment
focal_class.declarator: assignment
focal_class.modifier: private final
focal_class.original_string: private final Map<TopicPartition, TopicPartitionState> assignment;
focal_class.type: Map<TopicPartition, TopicPartitionState>
focal_class.var_name: assignment
focal_class.declarator: groupSubscription
focal_class.modifier: private final
focal_class.original_string: private final Set<String> groupSubscription;
focal_class.type: Set<String>
focal_class.var_name: groupSubscription
focal_class.declarator: needsPartitionAssignment
focal_class.modifier: private
focal_class.original_string: private boolean needsPartitionAssignment;
focal_class.type: boolean
focal_class.var_name: needsPartitionAssignment
focal_class.declarator: needsFetchCommittedOffsets
focal_class.modifier: private
focal_class.original_string: private boolean needsFetchCommittedOffsets;
focal_class.type: boolean
focal_class.var_name: needsFetchCommittedOffsets
focal_class.declarator: defaultResetStrategy
focal_class.modifier: private final
focal_class.original_string: private final OffsetResetStrategy defaultResetStrategy;
focal_class.type: OffsetResetStrategy
focal_class.var_name: defaultResetStrategy
focal_class.declarator: listener
focal_class.modifier: private
focal_class.original_string: private ConsumerRebalanceListener listener;
focal_class.type: ConsumerRebalanceListener
focal_class.var_name: listener
focal_class.declarator: SUBSCRIPTION_EXCEPTION_MESSAGE =
          "Subscription to topics, partitions and pattern are mutually exclusive"
focal_class.modifier: private static final
focal_class.original_string: private static final String SUBSCRIPTION_EXCEPTION_MESSAGE =
          "Subscription to topics, partitions and pattern are mutually exclusive";
focal_class.type: String
focal_class.var_name: SUBSCRIPTION_EXCEPTION_MESSAGE
focal_class.file: clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
focal_class.identifier: SubscriptionState
focal_class.class_method_signature: SubscriptionState.setSubscriptionType(SubscriptionType type)
focal_class.full_signature: private void setSubscriptionType(SubscriptionType type)
focal_class.identifier: setSubscriptionType
focal_class.modifiers: private
focal_class.parameters: (SubscriptionType type)
focal_class.return: void
focal_class.signature: void setSubscriptionType(SubscriptionType type)
focal_class.class_method_signature: SubscriptionState.SubscriptionState(OffsetResetStrategy defaultResetStrategy)
focal_class.full_signature: public  SubscriptionState(OffsetResetStrategy defaultResetStrategy)
focal_class.identifier: SubscriptionState
focal_class.modifiers: public
focal_class.parameters: (OffsetResetStrategy defaultResetStrategy)
focal_class.signature:  SubscriptionState(OffsetResetStrategy defaultResetStrategy)
focal_class.class_method_signature: SubscriptionState.subscribe(Collection<String> topics, ConsumerRebalanceListener listener)
focal_class.full_signature: public void subscribe(Collection<String> topics, ConsumerRebalanceListener listener)
focal_class.identifier: subscribe
focal_class.modifiers: public
focal_class.parameters: (Collection<String> topics, ConsumerRebalanceListener listener)
focal_class.return: void
focal_class.signature: void subscribe(Collection<String> topics, ConsumerRebalanceListener listener)
focal_class.class_method_signature: SubscriptionState.changeSubscription(Collection<String> topicsToSubscribe)
focal_class.full_signature: public void changeSubscription(Collection<String> topicsToSubscribe)
focal_class.identifier: changeSubscription
focal_class.modifiers: public
focal_class.parameters: (Collection<String> topicsToSubscribe)
focal_class.return: void
focal_class.signature: void changeSubscription(Collection<String> topicsToSubscribe)
focal_class.class_method_signature: SubscriptionState.groupSubscribe(Collection<String> topics)
focal_class.full_signature: public void groupSubscribe(Collection<String> topics)
focal_class.identifier: groupSubscribe
focal_class.modifiers: public
focal_class.parameters: (Collection<String> topics)
focal_class.return: void
focal_class.signature: void groupSubscribe(Collection<String> topics)
focal_class.class_method_signature: SubscriptionState.needReassignment()
focal_class.full_signature: public void needReassignment()
focal_class.identifier: needReassignment
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void needReassignment()
focal_class.class_method_signature: SubscriptionState.assignFromUser(Collection<TopicPartition> partitions)
focal_class.full_signature: public void assignFromUser(Collection<TopicPartition> partitions)
focal_class.identifier: assignFromUser
focal_class.modifiers: public
focal_class.parameters: (Collection<TopicPartition> partitions)
focal_class.return: void
focal_class.signature: void assignFromUser(Collection<TopicPartition> partitions)
focal_class.class_method_signature: SubscriptionState.assignFromSubscribed(Collection<TopicPartition> assignments)
focal_class.full_signature: public void assignFromSubscribed(Collection<TopicPartition> assignments)
focal_class.identifier: assignFromSubscribed
focal_class.modifiers: public
focal_class.parameters: (Collection<TopicPartition> assignments)
focal_class.return: void
focal_class.signature: void assignFromSubscribed(Collection<TopicPartition> assignments)
focal_class.class_method_signature: SubscriptionState.subscribe(Pattern pattern, ConsumerRebalanceListener listener)
focal_class.full_signature: public void subscribe(Pattern pattern, ConsumerRebalanceListener listener)
focal_class.identifier: subscribe
focal_class.modifiers: public
focal_class.parameters: (Pattern pattern, ConsumerRebalanceListener listener)
focal_class.return: void
focal_class.signature: void subscribe(Pattern pattern, ConsumerRebalanceListener listener)
focal_class.class_method_signature: SubscriptionState.hasPatternSubscription()
focal_class.full_signature: public boolean hasPatternSubscription()
focal_class.identifier: hasPatternSubscription
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasPatternSubscription()
focal_class.class_method_signature: SubscriptionState.unsubscribe()
focal_class.full_signature: public void unsubscribe()
focal_class.identifier: unsubscribe
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void unsubscribe()
focal_class.class_method_signature: SubscriptionState.getSubscribedPattern()
focal_class.full_signature: public Pattern getSubscribedPattern()
focal_class.identifier: getSubscribedPattern
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Pattern
focal_class.signature: Pattern getSubscribedPattern()
focal_class.class_method_signature: SubscriptionState.subscription()
focal_class.full_signature: public Set<String> subscription()
focal_class.identifier: subscription
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Set<String>
focal_class.signature: Set<String> subscription()
focal_class.class_method_signature: SubscriptionState.pausedPartitions()
focal_class.full_signature: public Set<TopicPartition> pausedPartitions()
focal_class.identifier: pausedPartitions
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Set<TopicPartition>
focal_class.signature: Set<TopicPartition> pausedPartitions()
focal_class.class_method_signature: SubscriptionState.groupSubscription()
focal_class.full_signature: public Set<String> groupSubscription()
focal_class.identifier: groupSubscription
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Set<String>
focal_class.signature: Set<String> groupSubscription()
focal_class.class_method_signature: SubscriptionState.assignedState(TopicPartition tp)
focal_class.full_signature: private TopicPartitionState assignedState(TopicPartition tp)
focal_class.identifier: assignedState
focal_class.modifiers: private
focal_class.parameters: (TopicPartition tp)
focal_class.return: TopicPartitionState
focal_class.signature: TopicPartitionState assignedState(TopicPartition tp)
focal_class.class_method_signature: SubscriptionState.committed(TopicPartition tp, OffsetAndMetadata offset)
focal_class.full_signature: public void committed(TopicPartition tp, OffsetAndMetadata offset)
focal_class.identifier: committed
focal_class.modifiers: public
focal_class.parameters: (TopicPartition tp, OffsetAndMetadata offset)
focal_class.return: void
focal_class.signature: void committed(TopicPartition tp, OffsetAndMetadata offset)
focal_class.class_method_signature: SubscriptionState.committed(TopicPartition tp)
focal_class.full_signature: public OffsetAndMetadata committed(TopicPartition tp)
focal_class.identifier: committed
focal_class.modifiers: public
focal_class.parameters: (TopicPartition tp)
focal_class.return: OffsetAndMetadata
focal_class.signature: OffsetAndMetadata committed(TopicPartition tp)
focal_class.class_method_signature: SubscriptionState.needRefreshCommits()
focal_class.full_signature: public void needRefreshCommits()
focal_class.identifier: needRefreshCommits
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void needRefreshCommits()
focal_class.class_method_signature: SubscriptionState.refreshCommitsNeeded()
focal_class.full_signature: public boolean refreshCommitsNeeded()
focal_class.identifier: refreshCommitsNeeded
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean refreshCommitsNeeded()
focal_class.class_method_signature: SubscriptionState.commitsRefreshed()
focal_class.full_signature: public void commitsRefreshed()
focal_class.identifier: commitsRefreshed
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void commitsRefreshed()
focal_class.class_method_signature: SubscriptionState.seek(TopicPartition tp, long offset)
focal_class.full_signature: public void seek(TopicPartition tp, long offset)
focal_class.identifier: seek
focal_class.modifiers: public
focal_class.parameters: (TopicPartition tp, long offset)
focal_class.return: void
focal_class.signature: void seek(TopicPartition tp, long offset)
focal_class.class_method_signature: SubscriptionState.assignedPartitions()
focal_class.full_signature: public Set<TopicPartition> assignedPartitions()
focal_class.identifier: assignedPartitions
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Set<TopicPartition>
focal_class.signature: Set<TopicPartition> assignedPartitions()
focal_class.class_method_signature: SubscriptionState.fetchablePartitions()
focal_class.full_signature: public Set<TopicPartition> fetchablePartitions()
focal_class.identifier: fetchablePartitions
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Set<TopicPartition>
focal_class.signature: Set<TopicPartition> fetchablePartitions()
focal_class.class_method_signature: SubscriptionState.partitionsAutoAssigned()
focal_class.full_signature: public boolean partitionsAutoAssigned()
focal_class.identifier: partitionsAutoAssigned
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean partitionsAutoAssigned()
focal_class.class_method_signature: SubscriptionState.position(TopicPartition tp, long offset)
focal_class.full_signature: public void position(TopicPartition tp, long offset)
focal_class.identifier: position
focal_class.modifiers: public
focal_class.parameters: (TopicPartition tp, long offset)
focal_class.return: void
focal_class.signature: void position(TopicPartition tp, long offset)
focal_class.class_method_signature: SubscriptionState.position(TopicPartition tp)
focal_class.full_signature: public Long position(TopicPartition tp)
focal_class.identifier: position
focal_class.modifiers: public
focal_class.parameters: (TopicPartition tp)
focal_class.return: Long
focal_class.signature: Long position(TopicPartition tp)
focal_class.class_method_signature: SubscriptionState.allConsumed()
focal_class.full_signature: public Map<TopicPartition, OffsetAndMetadata> allConsumed()
focal_class.identifier: allConsumed
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Map<TopicPartition, OffsetAndMetadata>
focal_class.signature: Map<TopicPartition, OffsetAndMetadata> allConsumed()
focal_class.class_method_signature: SubscriptionState.needOffsetReset(TopicPartition partition, OffsetResetStrategy offsetResetStrategy)
focal_class.full_signature: public void needOffsetReset(TopicPartition partition, OffsetResetStrategy offsetResetStrategy)
focal_class.identifier: needOffsetReset
focal_class.modifiers: public
focal_class.parameters: (TopicPartition partition, OffsetResetStrategy offsetResetStrategy)
focal_class.return: void
focal_class.signature: void needOffsetReset(TopicPartition partition, OffsetResetStrategy offsetResetStrategy)
focal_class.class_method_signature: SubscriptionState.needOffsetReset(TopicPartition partition)
focal_class.full_signature: public void needOffsetReset(TopicPartition partition)
focal_class.identifier: needOffsetReset
focal_class.modifiers: public
focal_class.parameters: (TopicPartition partition)
focal_class.return: void
focal_class.signature: void needOffsetReset(TopicPartition partition)
focal_class.class_method_signature: SubscriptionState.hasDefaultOffsetResetPolicy()
focal_class.full_signature: public boolean hasDefaultOffsetResetPolicy()
focal_class.identifier: hasDefaultOffsetResetPolicy
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasDefaultOffsetResetPolicy()
focal_class.class_method_signature: SubscriptionState.isOffsetResetNeeded(TopicPartition partition)
focal_class.full_signature: public boolean isOffsetResetNeeded(TopicPartition partition)
focal_class.identifier: isOffsetResetNeeded
focal_class.modifiers: public
focal_class.parameters: (TopicPartition partition)
focal_class.return: boolean
focal_class.signature: boolean isOffsetResetNeeded(TopicPartition partition)
focal_class.class_method_signature: SubscriptionState.resetStrategy(TopicPartition partition)
focal_class.full_signature: public OffsetResetStrategy resetStrategy(TopicPartition partition)
focal_class.identifier: resetStrategy
focal_class.modifiers: public
focal_class.parameters: (TopicPartition partition)
focal_class.return: OffsetResetStrategy
focal_class.signature: OffsetResetStrategy resetStrategy(TopicPartition partition)
focal_class.class_method_signature: SubscriptionState.hasAllFetchPositions()
focal_class.full_signature: public boolean hasAllFetchPositions()
focal_class.identifier: hasAllFetchPositions
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasAllFetchPositions()
focal_class.class_method_signature: SubscriptionState.missingFetchPositions()
focal_class.full_signature: public Set<TopicPartition> missingFetchPositions()
focal_class.identifier: missingFetchPositions
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Set<TopicPartition>
focal_class.signature: Set<TopicPartition> missingFetchPositions()
focal_class.class_method_signature: SubscriptionState.partitionAssignmentNeeded()
focal_class.full_signature: public boolean partitionAssignmentNeeded()
focal_class.identifier: partitionAssignmentNeeded
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean partitionAssignmentNeeded()
focal_class.class_method_signature: SubscriptionState.isAssigned(TopicPartition tp)
focal_class.full_signature: public boolean isAssigned(TopicPartition tp)
focal_class.identifier: isAssigned
focal_class.modifiers: public
focal_class.parameters: (TopicPartition tp)
focal_class.return: boolean
focal_class.signature: boolean isAssigned(TopicPartition tp)
focal_class.class_method_signature: SubscriptionState.isPaused(TopicPartition tp)
focal_class.full_signature: public boolean isPaused(TopicPartition tp)
focal_class.identifier: isPaused
focal_class.modifiers: public
focal_class.parameters: (TopicPartition tp)
focal_class.return: boolean
focal_class.signature: boolean isPaused(TopicPartition tp)
focal_class.class_method_signature: SubscriptionState.isFetchable(TopicPartition tp)
focal_class.full_signature: public boolean isFetchable(TopicPartition tp)
focal_class.identifier: isFetchable
focal_class.modifiers: public
focal_class.parameters: (TopicPartition tp)
focal_class.return: boolean
focal_class.signature: boolean isFetchable(TopicPartition tp)
focal_class.class_method_signature: SubscriptionState.pause(TopicPartition tp)
focal_class.full_signature: public void pause(TopicPartition tp)
focal_class.identifier: pause
focal_class.modifiers: public
focal_class.parameters: (TopicPartition tp)
focal_class.return: void
focal_class.signature: void pause(TopicPartition tp)
focal_class.class_method_signature: SubscriptionState.resume(TopicPartition tp)
focal_class.full_signature: public void resume(TopicPartition tp)
focal_class.identifier: resume
focal_class.modifiers: public
focal_class.parameters: (TopicPartition tp)
focal_class.return: void
focal_class.signature: void resume(TopicPartition tp)
focal_class.class_method_signature: SubscriptionState.addAssignedPartition(TopicPartition tp)
focal_class.full_signature: private void addAssignedPartition(TopicPartition tp)
focal_class.identifier: addAssignedPartition
focal_class.modifiers: private
focal_class.parameters: (TopicPartition tp)
focal_class.return: void
focal_class.signature: void addAssignedPartition(TopicPartition tp)
focal_class.class_method_signature: SubscriptionState.listener()
focal_class.full_signature: public ConsumerRebalanceListener listener()
focal_class.identifier: listener
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: ConsumerRebalanceListener
focal_class.signature: ConsumerRebalanceListener listener()
focal_method.body: public void position(TopicPartition tp, long offset) {
          assignedState(tp).position(offset);
      }
focal_method.class_method_signature: SubscriptionState.position(TopicPartition tp, long offset)
focal_method.full_signature: public void position(TopicPartition tp, long offset)
focal_method.identifier: position
focal_method.invocations: position assignedState
focal_method.modifiers: public
focal_method.parameters: (TopicPartition tp, long offset)
focal_method.return: void
focal_method.signature: void position(TopicPartition tp, long offset)