apache / apache/rocketmq-clients

When will support be available for the Node.js version of LiteSimpleConsumer (in Pull mode)?

Open
#1,343 4 comments 0 reactions 0 assignees View on GitHub
type/new feature
Dominant language
Java
Stars
505
Forks
313
Avg merge
11h 28m
Merged PRs (30d)
6

Description

### Programming Language of the Client

Node.js

### Is Your Feature Request Related to a Problem?

I want to use Node.js to implement the process of actively pulling messages from a specific LiteTopic.

### Describe the Solution You'd Like

**As shown in the following Java implementation:**

LiteSimpleConsumer consumer = provider.newLiteSimpleConsumerBuilder()
.setClientConfiguration(clientConfiguration)
.setConsumerGroup("GID_ai_session_worker_group")
.bindTopic("ai_session_events_topic")
.setAwaitDuration(Duration.ofSeconds(20))
.build();

consumer.subscribeLite("session_8f29a17c");//设置liteTopic,支持动态新增、移除liteTopic

while (running.get()) {
List messages = consumer.receive(
16,
Duration.ofSeconds(60));

for (MessageView message : messages) {
try {
handleIdempotently(message);
consumer.ack(message);
} catch (RetryableBusinessException e) {
log.warn("Leave message unacked for retry, messageId={}",
message.getMessageId(), e);
}
}
}

### Describe Alternatives You've Considered

Implement using Java

### Additional Context

_No response_

Contributor guide

No contributing guide indexed for this repository

Research direction

Start by comparing the requested Node.js client capability with the Java LiteSimpleConsumer example in the issue, focusing on Pull mode, LiteTopic subscription, receiving messages, and acknowledgements. Done means Node.js provides equivalent support for actively pulling from a LiteTopic, including dynamic subscription behavior and message acknowledgement.

Written by the indexing model from the issue text.

Assessment

Tech stack
java, node.js
Domain
backend, distributed-systems
Issue type
Feature
Difficulty
5/5
Estimated time
Over a week
Activity status
Active
Clarity
Mostly clear
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.