Handled few cases. Refactor code to run in multinode using executor. Added some APIs to simpleProducer and simpleCOnsumer