hermann
hermann copied to clipboard
Java Consumer enhancements
Create java based consumer:
- non blocking, can specify multiple threads
- supports multiple topics and streams
- takes in custom consumer worker classes
Currently, the JavaSimpleConsumer doesn't support these features.
Curious, does the MRI version have the same shortcomings? If so, I'd think this request could apply to both then.