diff --git a/playground/socketio/from_kafka.py b/playground/socketio/from_kafka.py index bb183fd..61b64c5 100644 --- a/playground/socketio/from_kafka.py +++ b/playground/socketio/from_kafka.py @@ -37,9 +37,10 @@ BOOTSTRAP_SERVERS = "del.ditscentre.in:9092" # ) 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("PD:", parent_dir) +# print("PD:", parent_dir) SSL_CONTEXT = get_ssl_context( ca_file = os.path.join(parent_dir, "creds", "kafka", "cert_authority.pem"),