flume-ng-redis
flume-ng-redis copied to clipboard
chiwanpark
Redis extension for Flume NG
This commit adds some metrics in order to measure successful/retried/failed deliveries of events.
Your FOSSA integration was successful! Attached in this PR is a badge and license report to track scan status in your README. Below are docs for integrating FOSSA license checks...
There are [some API changes](https://issues.apache.org/jira/browse/FLUME-2729) 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...
Can elaborate on how to use the the Redis Sink and the Redis source. Am I suppose to modify the config properties file, or the java file and then package...
Hi there! Thanks for this awesome plug-in! I noticed that Flume sources using this plug-in do not appear in the flume metrics page. Is there any chance this can be...
Hi there, Thanks for this awesome plug-in! I've been trying to inject fields like the source and environment names for our deployment via the Flume configuration using interceptors, but it...
publish ---->redis---->flume-ng-redis(source) when the flume-ng-redis(source) stop for some reason,the data will lose during this period。
Add PSUBSCRIBE-based Source to RedisSubscribeDrivenSource.