(20241224) Certs files test for Kafka.

This commit is contained in:
2024-12-24 14:31:53 +05:30
parent e3b37ea82c
commit 10be7881f4
+3 -2
View File
@@ -37,9 +37,10 @@ BOOTSTRAP_SERVERS = "del.ditscentre.in:9092"
# ) # )
cwd = files.get_cwd() cwd = files.get_cwd()
parent_dir = files.get_parent_directory(cwd, 2) # parent_dir = files.get_parent_directory(cwd, 2)
parent_dir = cwd
print("CWD:", cwd) print("CWD:", cwd)
print("PD:", parent_dir) # print("PD:", parent_dir)
SSL_CONTEXT = get_ssl_context( SSL_CONTEXT = get_ssl_context(
ca_file = os.path.join(parent_dir, "creds", "kafka", "cert_authority.pem"), ca_file = os.path.join(parent_dir, "creds", "kafka", "cert_authority.pem"),