'How can I filter data in ElasticSearch Sink Connector?

I am consuming data from the confluent audit log cluster and creating an index into the elastic search using the elastic search sink connector. I'm getting data of all the environments of my internal clusters. I want to apply the filters on the elastic sink connector level so I can filter my data based on the cluster-ID which I provide at the connector level.

Is anyone know how can I apply the filter on the elastic search sink connector?

Thank you!



Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source