ali-ons icon indicating copy to clipboard operation
ali-ons copied to clipboard

Aliyun Open Notification Service Client

Results 20 ali-ons issues
Sort by recently updated
recently updated
newest added

现在可以收到消除处理消息,但是没有ack 方法去消耗消息,因此云平台一直是未消费状态 ![image](https://user-images.githubusercontent.com/19756759/176634034-0b3bbb91-6e14-4293-a930-6b212be88f27.png)

对应code的文档可以在哪里看

嗨,你好。我用的是 "ali-ons": "^3.9.0", - 我在本地日志记录该消息已经完成消费,但是在控制台查询消费轨迹却显示该消息尚未消费。 - 当我想对消息进行消费验证时也会验证失败

refer to: https://help.aliyun.com/document_detail/43348.html

This addition allows the package to support user properties as seen in the [Message](https://javadoc.io/doc/com.aliyun.openservices/ons-api/latest/com/aliyun/openservices/ons/api/Message.html) class from the [com.aliyun.openservices](https://javadoc.io/doc/com.aliyun.openservices) [ons.api](https://javadoc.io/doc/com.aliyun.openservices/ons-api/latest/index.html) Java library. We have a client who uses this library to...

变量多次实例化Producer会出现 以下问题: No topic route info in name server for the topic: TBW102 See http://rocketmq.apache.org/docs/faq/ for further details. See http://rocketmq.apache.org/docs/faq/ for further details. 如果是仅实例一次 client 就不会出现这个问题 如果producer 多次实例化就就会出现 `class MQProducerService...

2 years ago, [this issue](https://github.com/ali-sdk/ali-ons/issues/16) requested __SHARDINGKEY system property support and it was never implemented. This is imlemented and is decoded successfully by the JAVA SDK.

**背景**: 因为 Producer 并不会持续发送数据,所以希望在收到任务调度的时候,初始化 Producer 并处理异步任务进行发送,任务结束后,销毁 Producer 以免占用额外的资源(CPU,内存,socket 连接等) **问题**: 使用 Producer 发送数据后,看到 socket 的建立以及周期任务的执行;但调用 `.close()` 方法后,日志显示已经 `unregister producer` 并且 `producer close` 了,但已建立的 socket 连接依然是 `ESTAB` 状态,且日志依然周期性的输出 mq 相关任务的执行 ali-one...

当 broker对fetchConsumeOffset请求返回错误信息 “Not found, V3_0_6_SNAPSHOT maybe this group consumer boot first”,rocket sdk并未做任何处理,仍是返回默认为-1的offset,直接影响新的消费组无法消费历史消息。 ``` long minOffset = this.brokerController.getMessageStore().getMinOffsetInQuque(requestHeader.getTopic(), requestHeader.getQueueId()); if (minOffset

maybe bug

Feature Request: Support STS. We need to allow aliyun account A to access MQ instance in account B. After reading the docs, I found that MQ support RAM STS AssumeRole...