How to increase insert Speed?

There is NiFi data pipeline in, which listen to system log and process received data and extract attributes by "ExtractText" processors Then make influx input format by "ReplaceText" and at the end insert to influxdb by "PutInflux" processor. But we get a long queue before putInflux processor because insert speed is too slower than produced data. Please help us to increase insert speed.

Data PipeLine

ReplaceText processor configuration : (view_stat -> measurement , Listing_id -> tag, event_id -> value , Timestamp -> time )

Sign In or Register to comment.