diff --git a/playground/socketio/to_kafka.py b/playground/socketio/to_kafka.py index e74cecd..057ab68 100644 --- a/playground/socketio/to_kafka.py +++ b/playground/socketio/to_kafka.py @@ -90,12 +90,12 @@ kafka_producer = ProducerKafka( bootstrap_servers = "del.ditscentre.in:9092", buffer_size = 1, security_protocol = "SSL", - ca_file = r"../../creds/kafka/cert_authority.pem", - cert_file = r"../../creds/kafka/fullchain.pem", - key_file = r"../../creds/kafka/privkey.pem" - # ca_file = os.path.join(parent_dir, "creds", "kafka", "cert_authority.pem"), - # cert_file = os.path.join(parent_dir, "creds", "kafka", "fullchain.pem"), - # key_file = os.path.join(parent_dir, "creds", "kafka", "privkey.pem") + # ca_file = r"../../creds/kafka/cert_authority.pem", + # cert_file = r"../../creds/kafka/fullchain.pem", + # key_file = r"../../creds/kafka/privkey.pem" + ca_file = os.path.join(parent_dir, "creds", "kafka", "cert_authority.pem"), + cert_file = os.path.join(parent_dir, "creds", "kafka", "fullchain.pem"), + key_file = os.path.join(parent_dir, "creds", "kafka", "privkey.pem") ) ) @@ -154,8 +154,8 @@ def main(): global INSTRUMENT_LOOKUP # Load Zerodha credentials: - creds = json.from_file(r"../../creds/zerodha/api.json") - # creds = json.from_file(os.path.join(parent_dir, "creds", "zerodha", "api.json")) + # creds = json.from_file(r"../../creds/zerodha/api.json") + creds = json.from_file(os.path.join(parent_dir, "creds", "zerodha", "api.json")) api_key = creds["apiKey"] access_token = creds["accessToken"]