flume-ng-redis
flume-ng-redis copied to clipboard
Add Flume 1.7.0 support
There are some API changes in PollableSource
since Flume 1.7.0 to allow backoff times to be configurable. We have to change the class hierarchy of RedisListDrivenSource
. The source implementation should be derived by AbstractPollableSource
.