in src/consumer/DefaultMQPushConsumerImpl.cpp [1067:1105]
void DefaultMQPushConsumerImpl::logConfigs() {
showClientConfigs();
LOG_WARN("MessageModel:%d", m_messageModel);
LOG_WARN("MessageModel:%s", m_messageModel == BROADCASTING ? "BROADCASTING" : "CLUSTERING");
LOG_WARN("ConsumeFromWhere:%d", m_consumeFromWhere);
switch (m_consumeFromWhere) {
case CONSUME_FROM_FIRST_OFFSET:
LOG_WARN("ConsumeFromWhere:%s", "CONSUME_FROM_FIRST_OFFSET");
break;
case CONSUME_FROM_LAST_OFFSET:
LOG_WARN("ConsumeFromWhere:%s", "CONSUME_FROM_LAST_OFFSET");
break;
case CONSUME_FROM_TIMESTAMP:
LOG_WARN("ConsumeFromWhere:%s", "CONSUME_FROM_TIMESTAMP");
break;
case CONSUME_FROM_LAST_OFFSET_AND_FROM_MIN_WHEN_BOOT_FIRST:
LOG_WARN("ConsumeFromWhere:%s", "CONSUME_FROM_LAST_OFFSET_AND_FROM_MIN_WHEN_BOOT_FIRST");
break;
case CONSUME_FROM_MAX_OFFSET:
LOG_WARN("ConsumeFromWhere:%s", "CONSUME_FROM_MAX_OFFSET");
break;
case CONSUME_FROM_MIN_OFFSET:
LOG_WARN("ConsumeFromWhere:%s", "CONSUME_FROM_MAX_OFFSET");
break;
default:
LOG_WARN("ConsumeFromWhere:%s", "UnKnown.");
break;
}
LOG_WARN("ConsumeThreadCount:%d", m_consumeThreadCount);
LOG_WARN("ConsumeMessageBatchMaxSize:%d", m_consumeMessageBatchMaxSize);
LOG_WARN("MaxMsgCacheSizePerQueue:%d", m_maxMsgCacheSize);
LOG_WARN("MaxReconsumeTimes:%d", m_maxReconsumeTimes);
LOG_WARN("PullMsgThreadPoolNum:%d", m_pullMsgThreadPoolNum);
LOG_WARN("AsyncPullMode:%s", m_asyncPull ? "true" : "false");
LOG_WARN("AsyncPullTimeout:%d ms", m_asyncPullTimeout);
}