diff --git a/playground/socketio/to_kafka.py b/playground/socketio/to_kafka.py index 6abfda2..c46e359 100644 --- a/playground/socketio/to_kafka.py +++ b/playground/socketio/to_kafka.py @@ -90,12 +90,12 @@ kafka_producer = ProducerKafka( bootstrap_servers = "del.ditscentre.in:9092", # buffer_memory = 3_35_54_432, security_protocol = "SSL", - ca_file = r"../../creds/kafka/cert_authority.pem", - cert_file = r"../../creds/kafka/fullchain.pem", - key_file = r"../../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 = r"../../creds/kafka/cert_authority.pem", + # cert_file = r"../../creds/kafka/fullchain.pem", + # key_file = r"../../creds/kafka/privkey.pem" + ca_file = "/etc/ssl/dbu/ca.pem", + cert_file = "/etc/ssl/dbu/fullchain.pem", + key_file = "/etc/ssl/dbu/privkey.pem" ), debug = False ) diff --git a/wsio/finstitutions/trading/main.py b/wsio/finstitutions/trading/main.py index e87263d..d4f11a4 100644 --- a/wsio/finstitutions/trading/main.py +++ b/wsio/finstitutions/trading/main.py @@ -349,12 +349,12 @@ async def init(): cwd = files.get_cwd() parent_dir = cwd ssl_context = get_ssl_context( - # ca_file = "/etc/ssl/dbu/ca.pem", - # cert_file = "/etc/ssl/dbu/fullchain.pem", - # key_file = "/etc/ssl/dbu/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 = "/etc/ssl/dbu/ca.pem", + cert_file = "/etc/ssl/dbu/fullchain.pem", + key_file = "/etc/ssl/dbu/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") ) sio.start_background_task( ticks_from_kafka,