Merge pull request #53 from Nasdaq/release-0.5.x

Update NasdaqKafkaAvroConsumer.py

Author: ruchirvaninasdaq

ncdssdk/src/main/python/ncdsclient/consumer/NasdaqKafkaAvroConsumer.py

@@ -105,7 +105,7 @@ def get_kafka_consumer(self, stream_name, timestamp=None):
                 self.logger.debug(
                     "offset: " + str(topic_partition.offset) + ", timestamp: " + str(timestamp))
                 offsets_for_times = kafka_consumer.offsets_for_times(
-                    [topic_partition], self.kafka_cfg.TIMEOUT)
+                    [topic_partition], self.kafka_props.get(self.kafka_config_loader.TIMEOUT))
             except Exception as e:
                 self.logger.exception(e)
                 sys.exit(0)