ilaipi opened a new issue, #342:
URL: https://github.com/apache/pulsar-client-node/issues/342
I create a consumer like this:
```
// test.js
const net = require('net');
const Pulsar = require('pulsar-client');
(async () => {
// Create a client
const client = new Pulsar.Client({
serviceUrl: 'my-pulsar-url', // e.g. pulsar://xxx:6650
});
// Create a consumer
const consumer = await client.subscribe({
topic: 'mytopic',
subscription: 'my-sub',
subscriptionType: 'Exclusive',
listener: (msg, msgConsumer) => {
console.log(msg.getData().toString());
msgConsumer.acknowledge(msg);
},
});
net.createServer().listen();
})();
```
When I run `node test.js`， I will receive msgs if have sent some msgs.
then keep the process live, I can't receive any more new msgs. and if I
close the process, and re-run `node test.js`, I will got all msgs sent just
now.
what's wrong?
thanks
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
