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)