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
--
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
