RocketMQ processor for Apache NIFI.
GetRocketMQ processor, which reads message from RocketMQ.
PutRedis processor, which extractd key and value from flow file, then put them into redis.
mvn clean install
Copy nifi-rocketmq-nar/target/nifi-rocketmq-nar-0.1.0.nar
to $NIFI_HOME/lib/
and restart NIFI.
Copy nifi-redis-nar/target/nifi-redis-nar-0.1.0.nar
to $NIFI_HOME/lib/
and restart NIFI.
Apache 2.0