From 6b57b309bc97c78cc1d9fc788de731e56bf342b5 Mon Sep 17 00:00:00 2001 From: Ruchir Vani <32844383+ruchirvaninasdaq@users.noreply.github.com> Date: Tue, 26 Mar 2024 17:12:46 -0400 Subject: [PATCH] Update NasdaqKafkaAvroConsumer.py Using kafka config --- .../main/python/ncdsclient/consumer/NasdaqKafkaAvroConsumer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ncdssdk/src/main/python/ncdsclient/consumer/NasdaqKafkaAvroConsumer.py b/ncdssdk/src/main/python/ncdsclient/consumer/NasdaqKafkaAvroConsumer.py index 089142a..328b18c 100644 --- a/ncdssdk/src/main/python/ncdsclient/consumer/NasdaqKafkaAvroConsumer.py +++ b/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)