Earlier I was using TransportClient in my app. Recently moving towards AWS manages Elastic Search services. Learned that AWS managed ES Cluster would not support TransportClient.
So migrating the code where it was using BulkProcessort to insert documents to ES. When I refactor the code as a part of ES documentation I added this line.
BulkProcessor bulkProcessor = BulkProcessor.builder(client::bulkAsync, listener).build();
and I get an error at client::bulkAsync saying Client is not a functional interface.
Need help understanding what am I doing wrong.
Document Link For reference,
