Kirk True created KAFKA-16565: --------------------------------- Summary: IncrementalAssignmentConsumerEventHandler throws error when attempting to remove a partition that isn't assigned Key: KAFKA-16565 URL: https://issues.apache.org/jira/browse/KAFKA-16565 Project: Kafka Issue Type: Bug Components: clients, consumer, system tests Affects Versions: 3.8.0 Reporter: Kirk True Fix For: 3.8.0
In {{{}verifiable_consumer.py{}}}, the Incremental {code:java} def handle_partitions_revoked(self, event): self.revoked_count += 1 self.state = ConsumerState.Rebalancing self.position = {} for topic_partition in event["partitions"]: topic = topic_partition["topic"] partition = topic_partition["partition"] self.assignment.remove(TopicPartition(topic, partition)) {code} If the {{self.assignment.remove()}} call is passed a {{TopicPartition}} that isn't in the list, an error is thrown. For now, we should first check that the {{TopicPartition}} is in the list, and if not, log a warning or something. -- This message was sent by Atlassian Jira (v8.20.10#820010)