[poll] Commit consume offset with specified MessageQueue

[ni-ze]

FEATURE REQUEST

1. Please describe the feature you are requesting.

Commit consume offset with specified MessageQueue

2. Provide any additional detail on your proposed use case for this feature.

when we use DefaultLitePullConsumer, we commit consume offset to broker, but there is only one commit api : commitSync, it will commit all MessageQueue you subscribe/assign. However, in streams scene, we need commit offset of specified MQ.

add commit api like:

commitSync(Map<MessageQueue, consumeOffset>)

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

[ni-ze]

I will add a pr to solve this.

[zhouxinyu]

Could please provide more details about you mentioned streams scene? Actually, we need pay more cautious when adding new APIs in rocketmq-client.

[ni-ze]

Could please provide more details about you mentioned streams scene? Actually, we need pay more cautious when adding new APIs in rocketmq-client.

state data in streams is partitioned, and sometimes only one of the MessageQueue offset will be commit.
such as only commit MQ0 or MQ1.