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/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 92794e15f3 [INLONG-9871][Sort] Use ZLIB as the default compression 
type of pulsar sink (#9872)
92794e15f3 is described below

commit 92794e15f3a418ce2396f911f61cc38b41a3b9b0
Author: vernedeng <verned...@apache.org>
AuthorDate: Mon Mar 25 18:07:02 2024 +0800

    [INLONG-9871][Sort] Use ZLIB as the default compression type of pulsar sink 
(#9872)
---
 .../inlong/sort/standalone/sink/pulsar/PulsarProducerCluster.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/pulsar/PulsarProducerCluster.java
 
b/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/pulsar/PulsarProducerCluster.java
index d2e85ebb11..b54dd44281 100644
--- 
a/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/pulsar/PulsarProducerCluster.java
+++ 
b/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/pulsar/PulsarProducerCluster.java
@@ -55,7 +55,7 @@ public class PulsarProducerCluster implements LifecycleAware {
 
     public static final Logger LOG = 
InlongLoggerFactory.getLogger(PulsarProducerCluster.class);
 
-    private static final String DEFAULT_COMPRESS_TYPE = "SNAPPY";
+    private static final String DEFAULT_COMPRESS_TYPE = "ZLIB";
     public static final String KEY_SERVICE_URL = "serviceUrl";
     public static final String KEY_AUTHENTICATION = "authentication";
     public static final String KEY_STATS_INTERVAL_SECONDS = 
"statsIntervalSeconds";

Reply via email to