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";