From f82a69f40bbc7ee414d202539e3e04b22b8c3f54 Mon Sep 17 00:00:00 2001
From: Anatolii Popov <anatolii.popov@aiven.io>
Date: Fri, 5 Jan 2024 16:18:01 +0200
Subject: [PATCH] RemoteFetcherTierStatemachine logging

---
 .../kafka/server/log/remote/metadata/storage/ConsumerTask.java   | 1 +
 1 file changed, 1 insertion(+)

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;