logs: Add partition to warning upon log Truncation (#489)

confluentinc · Dec 5, 2022 · f7fceaf · f7fceaf
1 parent 540b0b9
commit f7fceaf
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/state/PartitionState.java b/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/state/PartitionState.java
@@ -323,10 +323,11 @@ private void maybeTruncateBelowOrAbove(long bootstrapPolledOffset) {
 
         if (pollAboveExpected) {
             // previously committed offset record has been removed from the topic, so we need to truncate up to it
-            log.warn("Truncating state - removing records lower than {}. Offsets have been removed from the partition " +
+            log.warn("Truncating state - removing records lower than {} from partition {}. Offsets have been removed from the partition " +
                             "by the broker or committed offset has been raised. Bootstrap polled {} but expected {} from loaded commit data. " +
                             "Could be caused by record retention or compaction and offset reset policy LATEST.",
                     bootstrapPolledOffset,
+                    this.tp.partition(),
                     bootstrapPolledOffset,
                     expectedBootstrapRecordOffset);