Added the index to logs from KafkaWorker and ElasticsearchProducer