diff --git a/wsio/finstitutions/trading/main.py b/wsio/finstitutions/trading/main.py index 597ef42..ae83bd7 100644 --- a/wsio/finstitutions/trading/main.py +++ b/wsio/finstitutions/trading/main.py @@ -241,12 +241,12 @@ async def init(): bootstrap_servers = "del.ditscentre.in:9092", security_protocol = "SSL", ssl_context = get_ssl_context( - # ca_file = "../../../creds/kafka/cert_authority.pem", - # cert_file = "../../../creds/kafka/fullchain.pem", - # key_file = "../../../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 = "../../../creds/kafka/cert_authority.pem", + cert_file = "../../../creds/kafka/fullchain.pem", + key_file = "../../../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") ), auto_offset_reset = "latest" ),