diff --git a/kill.sh b/kill.sh index 8aaf299..159505a 100644 --- a/kill.sh +++ b/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: diff --git a/kill_sio.sh b/kill_sio.sh index 7b6fe16..fc73e28 100644 --- a/kill_sio.sh +++ b/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: diff --git a/run.sh b/run.sh index f21df25..702cf79 100644 --- a/run.sh +++ b/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: diff --git a/run_sio.sh b/run_sio.sh index 4f1442f..6e5291a 100644 --- a/run_sio.sh +++ b/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 diff --git a/wsio/finstitutions/trading/main.py b/wsio/finstitutions/trading/main.py index fcc44d3..307ced4 100644 --- a/wsio/finstitutions/trading/main.py +++ b/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(