commit 42762d05d6359568f5f817c5d05ca53ba9637239
author Li Zhanhui <lizhanhui@gmail.com> Tue Oct 12 09:34:58 2021 +0000
committer Li Zhanhui <lizhanhui@gmail.com> Tue Oct 12 09:34:58 2021 +0000
tree a28ed948a653e21b6fe069502f1ccf63a2e6c9b8
parent a03788ceca0ec96d1a86adb064a2e7fffa8c209d

Fix compile warning

.bazelrc

diff --git a/.bazelrc b/.bazelrc
index e92ef36..0f8f862 100644
--- a/.bazelrc
+++ b/.bazelrc
@@ -115,8 +115,10 @@
 build:ubsan --linkopt -lubsan
 
 # Use remote cache, --config=remote_cache See https://docs.bazel.build/versions/main/guide.html#--config
-build:remote_cache --remote_cache=http://11.122.50.85:9090
-test:remote_cache  --remote_cache=http://11.122.50.85:9090
+build:remote_cache --remote_cache=grpc://11.122.50.85:9092
+build:remote_cache --experimental_remote_downloader=grpc://11.122.50.85:9092
+test:remote_cache --remote_cache=http://11.122.50.85:9090
+test:remote_cache --remote_upload_local_results=true
 
 # Coverage options
 coverage --config=coverage

example/rocketmq/ExamplePullConsumer.cpp

diff --git a/example/rocketmq/ExamplePullConsumer.cpp b/example/rocketmq/ExamplePullConsumer.cpp
index b758e54..cd745ff 100644
--- a/example/rocketmq/ExamplePullConsumer.cpp
+++ b/example/rocketmq/ExamplePullConsumer.cpp
@@ -1,7 +1,9 @@
+#include <cstdlib>
+#include <iostream>
+
 #include "rocketmq/CredentialsProvider.h"
 #include "rocketmq/DefaultMQPullConsumer.h"
 #include "rocketmq/Logger.h"
-#include <cstdlib>
 
 int main(int argc, char* argv[]) {
   const char* group = "GID_group003";
@@ -28,6 +30,7 @@
     offset_query.policy = rocketmq::QueryOffsetPolicy::BEGINNING;
     auto offset_future = pull_consumer.queryOffset(offset_query);
     int64_t offset = offset_future.get();
+    std::cout << "offset: " << offset << std::endl;
   }
 
   pull_consumer.shutdown();

src/main/cpp/client/LogInterceptor.cpp

diff --git a/src/main/cpp/client/LogInterceptor.cpp b/src/main/cpp/client/LogInterceptor.cpp
index 88d1417..306a8df 100644
--- a/src/main/cpp/client/LogInterceptor.cpp
+++ b/src/main/cpp/client/LogInterceptor.cpp
@@ -5,6 +5,7 @@
 #include "google/protobuf/message.h"
 #include "rocketmq/Logger.h"
 #include "spdlog/spdlog.h"
+#include <cstddef>
 
 ROCKETMQ_NAMESPACE_BEGIN
 
@@ -67,7 +68,7 @@
     if (message) {
       auto* response = reinterpret_cast<google::protobuf::Message*>(message);
       std::string&& response_text = response->DebugString();
-      int limit = 1024;
+      std::size_t limit = 1024;
       if (response_text.size() <= limit) {
         SPDLOG_DEBUG("[Inbound] {}\n{}", client_rpc_info_->method(), response_text);
       } else {