To stream indexes into elasticsearch from dynamodb table on insertion

I am a novice into all this
Can anyone explain or point out to a reference/link which could explain how to stream indexes into elasticsearch from dynamodb table on insertion i.e. on inserting an item in dynamodb table the same record is to be updated in the elasticsearch too by trigger.
There are examples available in Python/Nodejs but cant find one in Java

Thanks