diff --git a/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java b/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java index 9103c20ba5126..6bf2b56cbe9d0 100644 --- a/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java +++ b/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java @@ -267,6 +267,7 @@ void maybeWaitForPartitionAssignments() throws InterruptedException { } processedAssignmentPartitions.add(utp.topicIdPartition); }); + log.error("Processed assignment partitions: {}", processedAssignmentPartitions); processedAssignmentOfUserTopicIdPartitions = new HashSet<>(processedAssignmentPartitions); clearResourcesForUnassignedUserTopicPartitions(processedAssignmentPartitions); isAllUserTopicPartitionsInitialized = false;