[KAFKA-1601] ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Abandoned
• Labels: transactions
• Assignee: Dong Lin
• Reporter: Dong Lin
• Created: 19/Aug/14 17:48
• Updated: 28/Feb/17 05:47
• Resolved: 28/Feb/17 05:47

Description

Implement buffered consumer logic in ConsumerTransactionBuffer class.

The class takes as input messages from non-transactional consumer (e.g. ConsoleConsumer, SimpleConsumer), recognizes transaction control requests (e.g. commit, abort), and outputs transaction messages when their transaction is committed.

By default, the class outputs non-transactional messages immediately on input.