RemoteFetcherTierStatemachine logging

aiven · Jan 5, 2024 · 18b2060 · 18b2060
1 parent c7eae32
commit 18b2060
Showing 1 changed file with 3 additions 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
@@ -171,6 +171,9 @@ private void processConsumerRecord(ConsumerRecord<byte[], byte[]> record) {
     private boolean shouldProcess(final RemoteLogMetadata metadata, final long recordOffset) {
         final TopicIdPartition tpId = metadata.topicIdPartition();
         final Long readOffset = readOffsetsByUserTopicPartition.get(tpId);
+        log.error("Checking if the event {} should be processed. Read offset: {} and record offset: {}",
+            metadata, readOffset, recordOffset);
+        log.error("processedAssignmentOfUserTopicIdPartitions: {}", processedAssignmentOfUserTopicIdPartitions);
         return processedAssignmentOfUserTopicIdPartitions.contains(tpId) && (readOffset == null || readOffset < recordOffset);
     }