run_benchmark.sh

#!/usr/bin/env bash
#
# Coordinates the Kafka streamer with blocking and reactive Java applications
# for a defined duration each. Run from the project root.
#
# Usage: ./run_benchmark.sh [DURATION_SECONDS]
#   DURATION_SECONDS: How long to run each Java app (default: 60)
#

set -e

SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
cd "$SCRIPT_DIR"

DURATION="${1:-60}"
STREAMER_PID=""

cleanup() {
    if [[ -n "$STREAMER_PID" ]] && kill -0 "$STREAMER_PID" 2>/dev/null; then
        echo ""
        echo "Stopping Kafka streamer (PID $STREAMER_PID)..."
        kill -TERM "$STREAMER_PID" 2>/dev/null || true
        wait "$STREAMER_PID" 2>/dev/null || true
    fi
}
trap cleanup EXIT

# Ensure JARs are built
echo "Building applications..."
(cd blocking_java && mvn -q package -DskipTests)
(cd reactive_java && mvn -q package -DskipTests)

# Start Kafka streamer
echo ""
echo "Starting Kafka streamer (rate 1000 msg/s)..."
cd streamer
./stratux-simulator --rate 1000 &
STREAMER_PID=$!
cd ..

# Allow Kafka and streamer to initialize
echo "Waiting 10 seconds for Kafka and streamer to initialize..."
sleep 10

# Run blocking application
echo ""
echo "=== Running blocking application for ${DURATION} seconds ==="
java -jar blocking_java/target/blocking-java-adsb-processor-1.0.0.jar &
BLOCKING_PID=$!
sleep "$DURATION"
echo "Stopping blocking application..."
kill -TERM "$BLOCKING_PID" 2>/dev/null || true
wait "$BLOCKING_PID" 2>/dev/null || true

# Brief pause between runs
echo ""
echo "Pausing 5 seconds before reactive run..."
sleep 5

# Run reactive application
echo ""
echo "=== Running reactive application for ${DURATION} seconds ==="
java -jar reactive_java/target/reactive-java-adsb-processor-1.0.0.jar &
REACTIVE_PID=$!
sleep "$DURATION"
echo "Stopping reactive application..."
kill -TERM "$REACTIVE_PID" 2>/dev/null || true
wait "$REACTIVE_PID" 2>/dev/null || true

echo ""
echo "Benchmark complete."