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);
}