adding quest-test changes

dreamerHarshit · Jan 14, 2020 · 649f970 · 649f970
1 parent 874888e
commit 649f970
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/qds_sdk/quest.py b/qds_sdk/quest.py
@@ -902,7 +902,7 @@ def _source_kafka(url, schema, data_format, broker, topics, topic_type, starting
             other_kafka_consumer_settings = {"kafkaConsumer.pollTimeoutMs": 512, "fetchOffset.numRetries": 3,
                                              "fetchOffset.retryIntervalMs": 10}
 
-        if use_registry is not "write" and registry_subject is None or registry_id is None:
+        if (use_registry is "schemaRegistry") and (registry_subject is None or registry_id is None):
             raise ParseError("registry_id and registry_subject cannot be empty if use_registry is auto fetch")
 
         data = {