Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Abandoned
-
None
-
None
-
None
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.