You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/11/03 05:09:21 UTC
[GitHub] [rocketmq-client-go] wenfengwang opened a new issue #737: [PullConsumer] Low level implementation
wenfengwang opened a new issue #737:
URL: https://github.com/apache/rocketmq-client-go/issues/737
**FEATURE REQUEST**
1. Please describe the feature you are requesting.
add implementation of LowLevel PullConsumer
2. Provide any additional detail on your proposed use case for this feature.
```go
type LowLevelPullConsumer interface {
// get n messages from specified queue with offset
PullFromQueue(ctx context.Context, mq *primitive.MessageQueue, offset int64, numbers int) (*primitive.PullResult, error)
// get queues of the topic
GetMessageQueues(ctx context.Context, topic string) []*mq primitive.MessageQueue
// get the offset of mq in groupName, if mq not exist, -1 will be return
CommittedOffset(groupName string, mq primitive.MessageQueue) (int64, error)
// seek comsume position to the offset, this api can be used to reset offset and commit offset
Seek(groupName string, mq primitive.MessageQueue, offset int64) error
// query offset according to timestamp(ms), the maximum offset that born time less than timestamp will be return
// if timestamp less than any message's born time, the earliest offset will be returned
// if timestamp great than any message's born time, the latest offset will be returned
Lookup(ctx context.Context, mq primitive.MessageQueue, timestamp int64) (int64, error)
}
```
3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?
must-have
4. If there are some sub-tasks using -[] for each subtask and create a corresponding issue to map to the sub task:
none
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] vongosling commented on issue #737: [PullConsumer] Low level implementation
Posted by GitBox <gi...@apache.org>.
vongosling commented on issue #737:
URL: https://github.com/apache/rocketmq-client-go/issues/737#issuecomment-958706496
Looking forward to it. We could stay compatible with java interface semantics.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] vongosling commented on issue #737: [PullConsumer] Low level implementation
Posted by GitBox <gi...@apache.org>.
vongosling commented on issue #737:
URL: https://github.com/apache/rocketmq-client-go/issues/737#issuecomment-958706496
Looking forward to it. We could stay compatible with java interface semantics.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] wenfengwang closed issue #737: [PullConsumer] Low level implementation
Posted by GitBox <gi...@apache.org>.
wenfengwang closed issue #737:
URL: https://github.com/apache/rocketmq-client-go/issues/737
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] vongosling commented on issue #737: [PullConsumer] Low level implementation
Posted by GitBox <gi...@apache.org>.
vongosling commented on issue #737:
URL: https://github.com/apache/rocketmq-client-go/issues/737#issuecomment-958706496
Looking forward to it. We could stay compatible with java interface semantics.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] vongosling commented on issue #737: [PullConsumer] Low level implementation
Posted by GitBox <gi...@apache.org>.
vongosling commented on issue #737:
URL: https://github.com/apache/rocketmq-client-go/issues/737#issuecomment-958706496
Looking forward to it. We could stay compatible with java interface semantics.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] zongtanghu commented on issue #737: [PullConsumer] Low level implementation
Posted by GitBox <gi...@apache.org>.
zongtanghu commented on issue #737:
URL: https://github.com/apache/rocketmq-client-go/issues/737#issuecomment-960353284
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] zongtanghu commented on issue #737: [PullConsumer] Low level implementation
Posted by GitBox <gi...@apache.org>.
zongtanghu commented on issue #737:
URL: https://github.com/apache/rocketmq-client-go/issues/737#issuecomment-960386468
Okay, good! It's yours! @shendongsd
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-go] shendongsd commented on issue #737: [PullConsumer] Low level implementation
Posted by GitBox <gi...@apache.org>.
shendongsd commented on issue #737:
URL: https://github.com/apache/rocketmq-client-go/issues/737#issuecomment-960373687
Could I develop this feature? @zongtanghu @wenfengwang
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org