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