[ https://issues.apache.org/jira/browse/TUBEMQ-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246481#comment-17246481 ]
Guocheng Zhang commented on TUBEMQ-443: --------------------------------------- Thanks [~leno] > 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 > Assignee: xianle cao > Priority: Major > Labels: pull-request-available > Time Spent: 20m > Remaining Estimate: 0h > > 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)