Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

consumerOptions无法访问ConsumeTimestamp字段 #715

Closed
whisper-a opened this issue Aug 17, 2021 · 4 comments
Closed

consumerOptions无法访问ConsumeTimestamp字段 #715

whisper-a opened this issue Aug 17, 2021 · 4 comments
Labels
question Further information is requested

Comments

@whisper-a
Copy link

如题,我当前使用github.com/apache/rocketmq-client-go/v2,当我想使用consumer.WithConsumeFromWhere(consumer.ConsumeFromTimestamp)这个类型时,
却发现对应的ConsumeTimestamp没有对外暴露设置的接口,请问这是你们有意为之吗??

@maixiaohai
Copy link
Contributor

#681
you can set consumer offset through console.

@maixiaohai maixiaohai added the question Further information is requested label Sep 2, 2021
@whisper-a
Copy link
Author

I think you may not understand the meaning of my question. I need to use the “ConsumeFromTimestamp” type, which means that this is a time-related option, but I can‘t pass in a timestamp? Because this option cannot be accessed externally.
image

@whisper-a
Copy link
Author

I think you may need to add an external access interface to the ConsumeFromTimestamp field like adding these options。
image

@ShannonDing
Copy link
Member

This parameter only takes effect for the consumer who added it for the first time, and the consumer will start to consume from the last consumption offset by default.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
question Further information is requested
Projects
None yet
Development

No branches or pull requests

4 participants