From e31857d0f1a20197a494d9aaf57fc60d77cb89b9 Mon Sep 17 00:00:00 2001 From: khushal Date: Thu, 26 Dec 2024 11:54:50 +0530 Subject: [PATCH] (20241226) ... --- playground/socketio/to_kafka.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) 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"]