[STORM-2092] optimize TridentKafkaState batch sending

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.0.0, 1.1.0
• Component/s: storm-kafka
• Assignee: Xin Wang
• Reporter: Xin Wang
• Created: 13/Sep/16 08:52
• Updated: 18/Sep/16 23:52
• Resolved: 18/Sep/16 23:52

Description

now TridentKafkaState.updateState send each tuple and call Future.get() immediately.
For better performance, we can send all requests first, and sync all to reduce waiting time.

Issue Links

• links to: GitHub Pull Request #1683