[jira] [Created] (TUBEMQ-443) TubemqSourceFunction class prints too many logs problem

["xianle cao (Jira)" <ji...@apache.org>]

xianle cao created TUBEMQ-443:
---------------------------------

             Summary: TubemqSourceFunction class prints too many logs problem
                 Key: TUBEMQ-443
                 URL: https://issues.apache.org/jira/browse/TUBEMQ-443
             Project: Apache TubeMQ
          Issue Type: Bug
            Reporter: xianle cao


When using the TubemqSourceFunction class to register the source table to consume tubemq topic data, this class prints too many info type logs, and the container log takes up a lot of disk space.

code:

```

ConsumerResult consumeResult = messagePullConsumer.getMessage();
 if (!consumeResult.isSuccess()) {
LOG.info("Could not consume messages from tubemq (errcode: {}, " +
"errmsg: {}).", consumeResult.getErrCode(),
consumeResult.getErrMsg());

...

}

possible improvements：

ConsumerResult consumeResult = messagePullConsumer.getMessage();
 if (!consumeResult.isSuccess()) {
 if (!(consumeResult.getErrCode() == 400 || consumeResult.getErrCode() == 404 ||
 consumeResult.getErrCode() == 405 || consumeResult.getErrCode() == 406 ||
 consumeResult.getErrCode() == 407 || consumeResult.getErrCode() == 408)) {
 LOG.info("Could not consume messages from tubemq (errcode: {}, " + "errmsg: {}).",
 consumeResult.getErrCode(), consumeResult.getErrMsg());
 }
...

}

```



--
This message was sent by Atlassian Jira
(v8.3.4#803005)