massakam commented on a change in pull request #121:
URL: https://github.com/apache/pulsar-client-node/pull/121#discussion_r490811096
##########
File path: tests/end_to_end.test.js
##########
@@ -376,5 +376,53 @@ const Pulsar = require('../index.js');
await reader.close();
await client.close();
});
+
+ test('Produce/Read (Compression)', async () => {
+ const client = new Pulsar.Client({
+ serviceUrl: 'pulsar://localhost:6650',
+ operationTimeoutSeconds: 30,
+ });
+ expect(client).not.toBeNull();
+
+ const topic = 'persistent://public/default/produce-read-compression';
+ const producer = await client.createProducer({
+ topic,
+ sendTimeoutMs: 30000,
+ batchingEnabled: true,
+ compressionType: 'ZSTD',
Review comment:
I don't think SNAPPY is available unless the SNAPPY library is installed
when the C++ client DEB package is built.
https://github.com/apache/pulsar/pull/4259/files#diff-bda8db832e446d092d38464123ed17bc
https://github.com/apache/pulsar/pull/4259/files#diff-7e441fcfcb20e339c71f7f8f48569579
So, even if you modify the Docker image, we cannot use SNAPPY immediately.
We have to wait for the next release of the C++ package.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
