Implemented CORE-521 Add a support for re-index through kafka.