This project is Java based alternative to mongo-connector. It is reading MongoDB oplog and reproduce appropriate actions in ElasticSearch. Code based on this tutorial
Producer is tailing MongoDB oplog and sends messages to JMS queue
Consumer is read messages from queue and do either INSERT, DELETE or UPDATE
- install and run OpenMQ with default settings.
- install and run MongoDB with default settings. And have collection and data inside.
- install ElasticSearch with default settings.
There are MainProducer.class and MainConsumer.class for testing purposes.