apache / apache/rocketmq-clients
When will support be available for the Node.js version of LiteSimpleConsumer (in Pull mode)?
- 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