diff --git a/examples/consumer.js b/examples/consumer.js index c754ac36de8c21..f0b370d7634022 100644 --- a/examples/consumer.js +++ b/examples/consumer.js @@ -30,6 +30,7 @@ const Pulsar = require('../index.js'); const consumer = await client.subscribe({ topic: 'persistent://public/default/my-topic', subscription: 'sub1', + subscriptionType: 'Shared', ackTimeoutMs: 10000, }); diff --git a/examples/consumer_tls_auth.js b/examples/consumer_tls_auth.js index e71b251d1b748c..7f846c5d78843e 100644 --- a/examples/consumer_tls_auth.js +++ b/examples/consumer_tls_auth.js @@ -36,6 +36,7 @@ const Pulsar = require('../index.js'); const consumer = await client.subscribe({ topic: 'persistent://public/default/my-topic', subscription: 'sub1', + subscriptionType: 'Shared', }); // Receive messages