nifi-rocketmq-bundle

RocketMQ processor for Apache NIFI.

GetRocketMQ processor, which reads messages from RocketMQ.

nifi-redis-bundle

PutRedis processor, which extracts key and value from flow file, then puts them into Redis.

How to use it?

1. find all "TODO" tags and set the configurations

2. mvn clean install

3. copy nifi-rocketmq-nar/target/nifi-rocketmq-nar-0.1.0.nar to $NIFI_HOME/lib/

4. copy nifi-redis-nar/target/nifi-redis-nar-0.1.0.nar to $NIFI_HOME/lib/

5. restart NiFi

License

Apache 2.0