This is an automated email from the ASF dual-hosted git repository. rxl pushed a commit to branch branch-2.6 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 828eb43a10989ae327a7af35723d98d0a835c849 Author: Matteo Merli <[email protected]> AuthorDate: Fri Jun 26 21:12:10 2020 -0700 [C++] Reduce log level for ack-grouping tracker (#7373) (cherry picked from commit 4138e712a389ff0885e4dddcc92d2176de8076ac) --- pulsar-client-cpp/lib/AckGroupingTrackerEnabled.cc | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pulsar-client-cpp/lib/AckGroupingTrackerEnabled.cc b/pulsar-client-cpp/lib/AckGroupingTrackerEnabled.cc index 6666a29..5c61cca 100644 --- a/pulsar-client-cpp/lib/AckGroupingTrackerEnabled.cc +++ b/pulsar-client-cpp/lib/AckGroupingTrackerEnabled.cc @@ -49,8 +49,8 @@ AckGroupingTrackerEnabled::AckGroupingTrackerEnabled(ClientImplPtr clientPtr, Ha executor_(clientPtr->getIOExecutorProvider()->get()), timer_(), mutexTimer_() { - LOG_INFO("ACK grouping is enabled, grouping time " << ackGroupingTimeMs << "ms, grouping max size " - << ackGroupingMaxSize); + LOG_DEBUG("ACK grouping is enabled, grouping time " << ackGroupingTimeMs << "ms, grouping max size " + << ackGroupingMaxSize); this->scheduleTimer(); } @@ -96,7 +96,7 @@ void AckGroupingTrackerEnabled::close() { void AckGroupingTrackerEnabled::flush() { auto cnx = this->handler_.getCnx().lock(); if (cnx == nullptr) { - LOG_WARN("Connection is not ready, grouping ACK failed."); + LOG_DEBUG("Connection is not ready, grouping ACK failed."); return; }
