1 files changed, 36 insertions, 0 deletions
diff --git a/test/kafka/kafka-client-loadtest/single-partition-test.sh b/test/kafka/kafka-client-loadtest/single-partition-test.sh
new file mode 100755
index 000000000..9c8b8a712
--- /dev/null
+++ b/test/kafka/kafka-client-loadtest/single-partition-test.sh
@@ -0,0 +1,36 @@
+#!/bin/bash
+# Single partition test - produce and consume from ONE topic, ONE partition
+
+set -e
+
+echo "================================================================"
+echo "    Single Partition Test - Isolate Missing Messages"
+echo "  - Topic: single-test-topic (1 partition only)"
+echo "  - Duration: 2 minutes"
+echo "  - Producer: 1 (50 msgs/sec)"
+echo "  - Consumer: 1 (reading from partition 0 only)"
+echo "================================================================"
+
+# Clean up
+make clean
+make start
+
+# Run test with single topic, single partition
+TEST_MODE=comprehensive \
+TEST_DURATION=2m \
+PRODUCER_COUNT=1 \
+CONSUMER_COUNT=1 \
+MESSAGE_RATE=50 \
+MESSAGE_SIZE=512 \
+TOPIC_COUNT=1 \
+PARTITIONS_PER_TOPIC=1 \
+VALUE_TYPE=avro \
+docker compose --profile loadtest up --abort-on-container-exit kafka-client-loadtest
+
+echo ""
+echo "================================================================"
+echo "                Single Partition Test Complete!"  
+echo "================================================================"
+echo ""
+echo "Analyzing results..."
+cd test-results && python3 analyze_missing.py