RemoteFetcherTierStatemachine logging

aiven · Jan 5, 2024 · f82a69f · f82a69f
1 parent 18b2060
commit f82a69f
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -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;