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

(20241226) ...

Browse Source
This commit is contained in:
khushal
2024-12-26 11:54:50 +05:30
parent 8e89575032
commit e31857d0f1
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
playground/socketio/to_kafka.py
+8 -8
View File
@@ -90,12 +90,12 @@ kafka_producer = ProducerKafka(
bootstrap_servers = "del.ditscentre.in:9092", bootstrap_servers = "del.ditscentre.in:9092",
buffer_size = 1, buffer_size = 1,
security_protocol = "SSL", security_protocol = "SSL",
ca_file = r"../../creds/kafka/cert_authority.pem", # ca_file = r"../../creds/kafka/cert_authority.pem",
cert_file = r"../../creds/kafka/fullchain.pem", # cert_file = r"../../creds/kafka/fullchain.pem",
key_file = r"../../creds/kafka/privkey.pem" # key_file = r"../../creds/kafka/privkey.pem"
# ca_file = os.path.join(parent_dir, "creds", "kafka", "cert_authority.pem"), ca_file = os.path.join(parent_dir, "creds", "kafka", "cert_authority.pem"),
# cert_file = os.path.join(parent_dir, "creds", "kafka", "fullchain.pem"), cert_file = os.path.join(parent_dir, "creds", "kafka", "fullchain.pem"),
# key_file = os.path.join(parent_dir, "creds", "kafka", "privkey.pem") key_file = os.path.join(parent_dir, "creds", "kafka", "privkey.pem")
) )
) )
@@ -154,8 +154,8 @@ def main():
global INSTRUMENT_LOOKUP global INSTRUMENT_LOOKUP
# Load Zerodha credentials: # Load Zerodha credentials:
creds = json.from_file(r"../../creds/zerodha/api.json") # creds = json.from_file(r"../../creds/zerodha/api.json")
# creds = json.from_file(os.path.join(parent_dir, "creds", "zerodha", "api.json")) creds = json.from_file(os.path.join(parent_dir, "creds", "zerodha", "api.json"))
api_key = creds["apiKey"] api_key = creds["apiKey"]
access_token = creds["accessToken"] access_token = creds["accessToken"]