change channel writable to debug avoid to disk full (apache#240)

to fix apache#239
hangc0276 · Nov 24, 2020 · 996486f · 996486f
1 parent 6c3ca75
commit 996486f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaCommandDecoder.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaCommandDecoder.java
@@ -88,7 +88,7 @@ public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exceptio
             // set auto read to true if channel is writable.
             ctx.channel().config().setAutoRead(true);
         } else {
-            log.warn("channel is not writable, disable auto reading for back pressing");
+            log.debug("channel is not writable, disable auto reading for back pressing");
             ctx.channel().config().setAutoRead(false);
             ctx.flush();
         }