(20241227) New shell scripts with modifications to the old ones.

kill.sh

@@ -3,8 +3,6 @@
 # Kill all the scripts:
 echo "Killing the script."
 pkill -9 -f "$(pwd)/api/main.py"
-pkill -9 -f "$(pwd)/playground/socketio/to_kafka.py"
-pkill -9 -f "$(pwd)/playground/socketio/from_kafka.py"
 
 # Get the name of the current directory,
 # and kill the monitors of the above scripts:

kill_sio.sh

@@ -2,6 +2,7 @@
 
 # Kill all the scripts:
 echo "Killing the script."
+pkill -9 -f "$(pwd)/playground/socketio/to_kafka.py"
 pkill -9 -f "$(pwd)/wsio/finstitutions/trading/main.py"
 
 # All done:

run.sh

@@ -3,8 +3,6 @@
 # Use this to run the microservice without any docker setup.
 source .venv/bin/activate
 python3 "$(pwd)/api/main.py" --host "0.0.0.0" --port 5106 --workers 4 --script-id "kps_cnv_KBC3MoaU" &
-python3 "$(pwd)/playground/socketio/to_kafka.py" &
-python3 "$(pwd)/playground/socketio/from_kafka.py" &
 deactivate
 
 # All done:

run_sio.sh

@@ -2,6 +2,7 @@
 
 # Use this to run the microservice without any docker setup.
 source .venv/bin/activate
+pkill -9 -f "$(pwd)/playground/socketio/to_kafka.py"
 python3 "$(pwd)/wsio/finstitutions/trading/main.py" --host "0.0.0.0" --port 5214 --script-id "kps_cnv_KBC3MoaU" &
 deactivate
 

wsio/finstitutions/trading/main.py

@@ -242,7 +242,7 @@ async def init():
         ticks_from_kafka,
         consumer = ConsumerKafka(
             topic = "tickers",
-            group_id = f"{SERVER_HOSTNAME}_tickers",
+            # group_id = f"{SERVER_HOSTNAME}_tickers",
             bootstrap_servers = "del.ditscentre.in:9092",
             security_protocol = "SSL",
             ssl_context = get_ssl_context(