change listOffset log level to debug (apache#259)

hangc0276 · Dec 9, 2020 · 024ea31 · 024ea31
1 parent c72cd72
commit 024ea31
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaRequestHandler.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaRequestHandler.java
@@ -848,7 +848,9 @@ private void handleListOffsetRequestV0(KafkaHeaderAndRequest listOffset,
 
         // in v0, the iterator is offsetData,
         // in v1, the iterator is partitionTimestamps,
-        log.warn("received a v0 listOffset: {}", request.toString(true));
+        if (log.isDebugEnabled()) {
+            log.debug("received a v0 listOffset: {}", request.toString(true));
+        }
         request.offsetData().entrySet().stream().forEach(tms -> {
             TopicPartition topic = tms.getKey();
             String fullPartitionName = KopTopic.toString(topic);