khushalps/api_utils_converse_v2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

(20241227) Kafka cert test.

Browse Source
This commit is contained in:
khushal
2024-12-27 17:37:05 +05:30
parent fb29011749
commit 6f2285c536
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
wsio/finstitutions/trading/main.py
+6 -6
View File
@@ -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"
),