(rocketmq-clients) branch master updated: test(nodejs): use a fixed consumer group in the simple consumer integration test (#1376)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

RongtongJin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new fc088d4a test(nodejs): use a fixed consumer group in the simple 
consumer integration test (#1376)
fc088d4a is described below

commit fc088d4a536af5e67281fea41b7911f10d1e8262
Author: zhaohai <33314633+zhaohai...@users.noreply.github.com>
AuthorDate: Tue Sep 15 17:02:24 2026 +0800

    test(nodejs): use a fixed consumer group in the simple consumer integration 
test (#1376)
    
    SimpleConsumer#should receive success generated a random consumer group on 
every
    run (nodejs-unittest-group-${randomUUID()}). RocketMQ 5.5.1's proxy resolves
    subscription groups with a plain table lookup
    (LocalMetadataService#getSubscriptionGroupConfig -> 
getSubscriptionGroupTable().get())
    instead of the auto-creating findSubscriptionGroupConfig, so an unknown 
group
    makes the proxy reject the client telemetry stream with "group not found" 
and
    startup() never resolves - the test hangs until the runner times out.
    
    Use the shared fixed group already used by the other cases in this file, so 
the
    group can be pre-created on the broker. The random tag is kept, so the 
assertions
    still only match the messages produced by this run.
    
    Verified against a live RocketMQ 5.5.1 broker (proxy :8081): integration 
suite
    12/12 (index, Producer 6, SimpleConsumer 4, ProducerRecall 1), where the 
random
    group previously hung the run.
---
 nodejs/test/consumer/SimpleConsumer.test.ts |  2 +-
 nodejs/tsconfig.test.json                   | 10 ++++++++++
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/nodejs/test/consumer/SimpleConsumer.test.ts 
b/nodejs/test/consumer/SimpleConsumer.test.ts
index 3bad0ebd..1573f1f5 100644
--- a/nodejs/test/consumer/SimpleConsumer.test.ts
+++ b/nodejs/test/consumer/SimpleConsumer.test.ts
@@ -99,7 +99,7 @@ describe('test/consumer/SimpleConsumer.test.ts', () => {
         endpoints,
         namespace,
         sessionCredentials,
-        consumerGroup: `nodejs-unittest-group-${randomUUID()}`,
+        consumerGroup: 'nodejs-unittest-group',
         subscriptions: new Map().set(topic, new FilterExpression(tag)),
       });
       await simpleConsumer.startup();
diff --git a/nodejs/tsconfig.test.json b/nodejs/tsconfig.test.json
new file mode 100644
index 00000000..883d7fde
--- /dev/null
+++ b/nodejs/tsconfig.test.json
@@ -0,0 +1,10 @@
+{
+  "extends": "./tsconfig.json",
+  "compilerOptions": {
+    "rootDir": ".",
+    "outDir": "./dist",
+    "noEmit": false
+  },
+  "include": [ "src", "test" ],
+  "exclude": [ "node_modules", "dist" ]
+}