You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/10/27 16:45:43 UTC
[GitHub] [rocketmq-flink] deemogsw opened a new issue, #69: Version below 4.6.0 does not support DefaultLitePullConsumer
deemogsw opened a new issue, #69:
URL: https://github.com/apache/rocketmq-flink/issues/69
DefaultMQPullConsumer has been instead of by DefaultLitePullConsumer.After I rebase master into my develop branch,some mistakes have occurred.And my company uses version `4.3`
<img width="1327" alt="image" src="https://user-images.githubusercontent.com/48081481/198344964-18fd40e4-5e6e-4e18-915c-3a088a9dc613.png">
So I run the old version and everything is normal.I'm thing about the compatibility.After reading the documents,I found the following explanation.
<img width="890" alt="image" src="https://user-images.githubusercontent.com/48081481/198346072-72afb48a-c725-49dd-afc8-cd5b88201cdf.png">
Since not all version support `LitePull`.The generality of the code is very poor, and users need to spend a lot of effort merging the code to use the full functionality.
If there is no particularly big improvement, is it necessary to replace way of pull?
There are still many features to be added,some bugs to be fixed. See #63
So I think that resetting the commit is a good choice.After all of functions are available,It's not too late to replace `CommonPull` by `LitePull` in a new branch or tag.
--
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: commits-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-flink] deemogsw commented on issue #69: Version below 4.6.0 does not support DefaultLitePullConsumer
Posted by GitBox <gi...@apache.org>.
deemogsw commented on issue #69:
URL: https://github.com/apache/rocketmq-flink/issues/69#issuecomment-1293807622
@SteNicholas @zhouxinyu Please pay attention to this problem，thanks
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-flink] SteNicholas commented on issue #69: Version below 4.6.0 does not support DefaultLitePullConsumer
Posted by GitBox <gi...@apache.org>.
SteNicholas commented on issue #69:
URL: https://github.com/apache/rocketmq-flink/issues/69#issuecomment-1294286206
@deemogsw, could you add wechat 834031959 to discuss?
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-flink] zhouxinyu commented on issue #69: Version below 4.6.0 does not support DefaultLitePullConsumer
Posted by GitBox <gi...@apache.org>.
zhouxinyu commented on issue #69:
URL: https://github.com/apache/rocketmq-flink/issues/69#issuecomment-1376857998
Hello @deemogsw, sorry for the late reply. If you have some fixes about the current version, could you please merge it to the upstream through a PR?
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-flink] gj-zhang commented on issue #69: Version below 4.6.0 does not support DefaultLitePullConsumer
Posted by GitBox <gi...@apache.org>.
gj-zhang commented on issue #69:
URL: https://github.com/apache/rocketmq-flink/issues/69#issuecomment-1370445432
is there any progress ?
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-flink] deemogsw commented on issue #69: Version below 4.6.0 does not support DefaultLitePullConsumer
Posted by GitBox <gi...@apache.org>.
deemogsw commented on issue #69:
URL: https://github.com/apache/rocketmq-flink/issues/69#issuecomment-1376839817
> is there any progress ?
The original contributors disappeared and have not fix this problem.Maintainer also rarely manage.
You can visit my homepage for project of rocketMQ-flink-connector.This is the latest version we use in production.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-flink] deemogsw commented on issue #69: Version below 4.6.0 does not support DefaultLitePullConsumer
Posted by GitBox <gi...@apache.org>.
deemogsw commented on issue #69:
URL: https://github.com/apache/rocketmq-flink/issues/69#issuecomment-1376938657
> Hello @deemogsw, sorry for the late reply. If you have some fixes about the current version, could you please merge it to the upstream through a PR?
Sorry, I don't know much about lite pull.I can fix known problems, but I can't solve hidden problems because we use a lower version with defaultMQPull.So I suggest supporting this feature in the new branch.
I just removed the problematic PR and add some updates in our internal version.All of patches have been merged into this or waiting for merging.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-flink] kevinnerd commented on issue #69: Version below 4.6.0 does not support DefaultLitePullConsumer
Posted by "kevinnerd (via GitHub)" <gi...@apache.org>.
kevinnerd commented on issue #69:
URL: https://github.com/apache/rocketmq-flink/issues/69#issuecomment-1687522373
> > is there any progress ?
> > The original contributors disappeared and have not fix this problem.Maintainer also rarely manage.
> > You can visit my homepage for project of rocketMQ-flink-connector.This is the latest version we use in production.
Hello @deemogsw , your rocketMQ-flink-connector project solved my problem, thanks a lot~~ save me a lot of time.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-flink] deemogsw commented on issue #69: Version below 4.6.0 does not support DefaultLitePullConsumer
Posted by GitBox <gi...@apache.org>.
deemogsw commented on issue #69:
URL: https://github.com/apache/rocketmq-flink/issues/69#issuecomment-1295919302
Maybe It has another problems.For testing ,i run the V4.8 in docker container.But it is still failed
<img width="1267" alt="image" src="https://user-images.githubusercontent.com/48081481/198845597-fcb37885-0d66-485c-88e5-c1814bcea8e6.png">
So I read the documents again.In Assign mode,consumer must assign MessageQueues before seek offset.
<img width="871" alt="image" src="https://user-images.githubusercontent.com/48081481/198845717-e6b569ad-2217-45b0-b5ae-e89d5285d101.png">
But #46 use like this:
<img width="948" alt="image" src="https://user-images.githubusercontent.com/48081481/198846208-e5192ff9-bdfd-4c28-a53d-63d68acb5c17.png">
It use a subscribe mode.It alse use seek() function.
I guess if the exception is caused by an api usage error.So i make a test like this.
<img width="1465" alt="image" src="https://user-images.githubusercontent.com/48081481/198846169-7ca355ad-118c-46a9-91e9-22497503957d.png">
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org