You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rx...@apache.org on 2020/07/29 09:38:57 UTC
[pulsar] 01/14: [C++] Reduce log level for ack-grouping tracker
(#7373)
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 <mm...@apache.org>
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;
}