You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/04/02 11:13:35 UTC

[incubator-inlong] branch master updated: [INLONG-3450][SDK] Sort-SDK change ack log from info to debug (#3465)

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 2d3aa29  [INLONG-3450][SDK] Sort-SDK change ack log from info to debug (#3465)
2d3aa29 is described below

commit 2d3aa29a6a87457b482cbfa6340062642eef3bbb
Author: wardli <95...@users.noreply.github.com>
AuthorDate: Sat Apr 2 19:13:30 2022 +0800

    [INLONG-3450][SDK] Sort-SDK change ack log from info to debug (#3465)
---
 .../src/main/java/org/apache/inlong/sdk/sort/impl/SortClientImpl.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/SortClientImpl.java b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/SortClientImpl.java
index 7ad5857..ac17551 100644
--- a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/SortClientImpl.java
+++ b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/SortClientImpl.java
@@ -101,7 +101,7 @@ public class SortClientImpl extends SortClient {
     @Override
     public void ack(String msgKey, String msgOffset)
             throws Exception {
-        logger.info("ack:{} offset:{}", msgKey, msgOffset);
+        logger.debug("ack:{} offset:{}", msgKey, msgOffset);
         InLongTopicFetcher inLongTopicFetcher = getFetcher(msgKey);
         inLongTopicFetcher.ack(msgOffset);
     }