machi1990 commented on code in PR #13665: URL: https://github.com/apache/kafka/pull/13665#discussion_r1230661381
########## clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java: ########## @@ -351,6 +359,10 @@ private Exception invokePartitionsRevoked(final SortedSet<TopicPartition> revoke final long startMs = time.milliseconds(); listener.onPartitionsRevoked(revokedPartitions); sensors.revokeCallbackSensor.record(time.milliseconds() - startMs); + // remove the offset metadata cache for revoked partitions + for (TopicPartition revokedPartition: revokedPartitions) { + this.committedTopicPartitionOffsetsCache.remove(revokedPartition); + } Review Comment: You are correct, we are missing this verification. I'll add them! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org