diff --git a/lib/MultiTopicsConsumerImpl.cc b/lib/MultiTopicsConsumerImpl.cc index 4f5f9f71..913655d9 100644 --- a/lib/MultiTopicsConsumerImpl.cc +++ b/lib/MultiTopicsConsumerImpl.cc @@ -262,7 +262,7 @@ void MultiTopicsConsumerImpl::subscribeTopicPartitions( &MultiTopicsConsumerImpl::handleSingleConsumerCreated, get_shared_this_ptr(), std::placeholders::_1, std::placeholders::_2, partitionsNeedCreate, topicSubResultPromise)); consumers_.put(topicName->toString(), consumer); - LOG_DEBUG("Creating Consumer for - " << topicName << " - " << consumerStr_); + LOG_DEBUG("Creating Consumer for - " << topicName->toString() << " - " << consumerStr_); consumer->start(); } else {