ableegoldman commented on a change in pull request #10788: URL: https://github.com/apache/kafka/pull/10788#discussion_r683902306
########## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ########## @@ -517,9 +526,9 @@ void handleRevocation(final Collection<TopicPartition> revokedPartitions) { } if (!remainingRevokedPartitions.isEmpty()) { - log.warn("The following partitions {} are missing from the task partitions. It could potentially " + + log.debug("The following revoked partitions {} are missing from the current task partitions. It could potentially " + Review comment: Making this debug since `warn` seems too intense, and I'm not sure it's even worthy of `info` -- also, with named topologies you would expect to see this almost every time a topology is removed since the thread will try to close those tasks as soon as it notices the topology's removal -- 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