Files
zeekay ca324e043d feat: replace MinIO fork with SeaweedFS-engine Hanzo S3
Kill MinIO; migrate object storage to SeaweedFS, rebranded Hanzo S3.
- module github.com/hanzoai/s3 (all 1920 imports rewritten); seaweedfs/{raft,goexif,go-fuse,cockroachdb-parser} kept as deps
- binary weed -> s3; display brand SeaweedFS -> Hanzo S3 (Server/version/admin); wire identifiers unchanged for S3 compat
- Dockerfile builds s3 (CGO_ENABLED=0, ldflags) -> ghcr.io/hanzoai/s3 via shared CI
- MinIO preserved in git history (prior main)
2026-06-19 23:34:08 -07:00

37 lines
1.1 KiB
Bash
Executable File

#!/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