We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7d6cecb commit 2e7b1a8Copy full SHA for 2e7b1a8
1 file changed
handwritten/pubsub/src/message-stream.ts
@@ -27,6 +27,7 @@ import {Duration} from './temporal';
27
import {ExponentialRetry} from './exponential-retry';
28
import {DebugMessage} from './debug';
29
import {logs as baseLogs} from './logs';
30
+import {randomUUID} from 'crypto';
31
32
/**
33
* Loggers. Exported for unit tests.
@@ -395,7 +396,7 @@ export class MessageStream extends PassThrough {
395
396
maxOutstandingBytes: this._subscriber.useLegacyFlowControl
397
? 0
398
: this._subscriber.maxBytes,
- clientId: 'node-pubsub',
399
+ clientId: randomUUID().toString(),
400
protocolVersion: 1, // Set protocol version to fulfill keepalive capabilities
401
};
402
const otherArgs = {
0 commit comments