diff --git a/ncds-sdk/src/main/java/com/nasdaq/ncdsclient/internal/ReadSchemaTopic.java b/ncds-sdk/src/main/java/com/nasdaq/ncdsclient/internal/ReadSchemaTopic.java index 4dc89cf..6889b8f 100644 --- a/ncds-sdk/src/main/java/com/nasdaq/ncdsclient/internal/ReadSchemaTopic.java +++ b/ncds-sdk/src/main/java/com/nasdaq/ncdsclient/internal/ReadSchemaTopic.java @@ -35,7 +35,7 @@ public ReadSchemaTopic(){ public Schema readSchema(String topic) throws Exception { KafkaConsumer schemaConsumer= getConsumer("Control-"+getClientID(securityProps)); schemaConsumer.subscribe(Collections.singletonList(controlSchemaName)); - Duration sec = Duration.ofSeconds(5); + Duration sec = Duration.ofSeconds(10); Schema messageSchema = null; ConsumerRecord lastRecord=null; @@ -93,7 +93,7 @@ public Set getTopics() throws Exception{ KafkaConsumer schemaConsumer= getConsumer("Control-"+getClientID(securityProps)); schemaConsumer.subscribe(Collections.singletonList(controlSchemaName)); - Duration sec = Duration.ofSeconds(5); + Duration sec = Duration.ofSeconds(10); while (true) { ConsumerRecords schemaRecords = schemaConsumer.poll(sec); if(schemaRecords.isEmpty()){ @@ -160,4 +160,4 @@ private Schema internalSchema (String topic) throws Exception { } } - } \ No newline at end of file + }