search

dapr / components-contrib

Community driven, reusable components for distributed apps
Apache License 2.0
546 stars 477 forks source link

[RocketMQ] is the `consumeTimeout` available? what the time unit is it? #2756

Closed naah69 closed 1 year ago

naah69 commented 1 year ago

Is the consumeTimeout available? What the time unit is it?

I can't find the property in dapr rocketmq doc

but i found it in source code. https://github.com/dapr/components-contrib/blob/b4cdc7a3cae9200cf68d98447cd02314d6329530/pubsub/rocketmq/metadata.go#L129

and it is not set in the source code https://github.com/dapr/components-contrib/blob/6be5499d369221ca542c2149dfb9914260c6a41b/pubsub/rocketmq/rocketmq.go#L122

naah69 commented 1 year ago

@jinjianfeng-chn can u answer my question?

naah69 commented 1 year ago

maybe we should wait for this https://github.com/apache/rocketmq-client-go/blob/25003f6f083d3347a169ceb472295c272fbdf7a6/consumer/option.go#L349