Description
I have a need to accept incoming events and process them with multiple instances of a custom sink. Each sink must pull from its own channel so the sources needs a way to publish to multiple channels. The LoadBalancingChannelSelector operates similar to the LoadBalancingSinkProcessor excepts it distributes events to channels, thus effectively creating multiple threads to process the events.
Attachments
Issue Links
- is duplicated by
-
FLUME-944 Implement a Load-balancing channel selector for distributing the load over many channels.
-
- Closed
-