This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new b7e3fdd  Downgrade pulsar-client CLI consume warning message (#1485) 
(#2012)
b7e3fdd is described below

commit b7e3fdd0976b4703cc858ddebf7e9db17d9a9fd8
Author: Ivan Kelly <[email protected]>
AuthorDate: Thu Jun 21 18:26:53 2018 +0200

    Downgrade pulsar-client CLI consume warning message (#1485) (#2012)
    
    Previously this log would spam the stdout if there were no messages
    coming in. The message wasn't even factually correct, as the timeout
    had changed.
    
    I've downgraded the log warn to debug can corrected the factual error.
---
 .../src/main/java/org/apache/pulsar/client/cli/CmdConsume.java          | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
index caa2a12..f19e6a5 100644
--- 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
+++ 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
@@ -132,7 +132,7 @@ public class CmdConsume {
 
                 Message<byte[]> msg = consumer.receive(5, TimeUnit.SECONDS);
                 if (msg == null) {
-                    LOG.warn("No message to consume after waiting for 20 
seconds.");
+                    LOG.debug("No message to consume after waiting for 5 
seconds.");
                 } else {
                     numMessagesConsumed += 1;
                     System.out.println(MESSAGE_BOUNDARY);

Reply via email to