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 <[email protected]>
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);
}
