[ROCKETMQ-276] rocketmq-spark

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 4.1.0-incubating
• Component/s: rocketmq-externals
• Labels: patch
• Flags: Patch
• Assignee: dongeforever
• Reporter: weiqichx
• Created: 23/Aug/17 10:13
• Updated: 05/Sep/17 14:58

Description

When Multiple-broker in queue running, appear Failed to get records for rs-consumer after polling.

Cause: RocketMqRDDIterator hasNext used offsetRange sum all broker. however the first broker doesn't has next MessageExt. but index is serial in next function.

fixed patch in attachment.