You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2020/06/27 04:12:19 UTC
[pulsar] branch master updated: [C++] Reduce log level for
ack-grouping tracker (#7373)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 4138e71 [C++] Reduce log level for ack-grouping tracker (#7373)
4138e71 is described below
commit 4138e712a389ff0885e4dddcc92d2176de8076ac
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Fri Jun 26 21:12:10 2020 -0700
[C++] Reduce log level for ack-grouping tracker (#7373)
---
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;
}