ni-ze commented on PR #276: URL: https://github.com/apache/rocketmq-streams/pull/276#issuecomment-1585619825
@Jargon9 It does need seek to the beginning of use topic. But we can reset the offset after the rebalance, like the recover the state of shuffle topic. The details can be find in class MessageQueueListenerWrapper, where the state is recovered after rebalance. Reset user topic offset can be invoked here, I think. Sorry for late to reply you. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
