From 6f2285c53631272270906b8fd28a2232c4abbf29 Mon Sep 17 00:00:00 2001 From: khushal Date: Fri, 27 Dec 2024 17:37:05 +0530 Subject: [PATCH] (20241227) Kafka cert test. --- wsio/finstitutions/trading/main.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) 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" ),