Pass retry_on_conflict parameter for fluentd

I had configured fluentd to listen to messages from rabbitmq and persist into elasticsearch 7x. I see my records are gettting flushed in a bulk request the request body is


how can I pass the retry_on_conflict parameter by configuring it in fluentdcp template.
There is a 409 exception I am getting and if I can pass this parameter then it will retry