FluentD with Opensearch

I am currently working on creating architecture which support streaming data. So bit confused as it is possible to work with fluentd where datalake is opensearch. So overall general idea is => beat → kafka → fluentd → opensearch. ?