ทดสอบ Performance
ให้ได้ผลจริง

from kafka import KafkaProducer
import json, time, statistics

producer = KafkaProducer(
    bootstrap_servers=['kafka-broker-1:9092', 'kafka-broker-2:9092'],
    acks='all',                          # Financial: Zero message loss
    retries=3, batch_size=16384, linger_ms=5, compression_type='snappy',
    value_serializer=lambda v: json.dumps(v).encode('utf-8')
)
latencies, errors, sent = [], [], 0

def on_send_success(metadata, t_send):
    global sent
    latencies.append((time.time() - t_send) * 1000); sent += 1

TARGET_RATE = 50_000; DURATION = 300; interval = 1 / TARGET_RATE
start = time.time()
while time.time() - start < DURATION:
    t = time.time()
    producer.send('payment-events', value={'txn_id': f'TXN-{sent}', 'ts': t}) \
            .add_callback(on_send_success, t).add_errback(lambda e: errors.append(str(e)))
    time.sleep(max(0, interval - (time.time() - t)))
producer.flush()
p95 = statistics.quantiles(latencies, n=100)[94]
print(f"Sent: {sent:,} | Errors: {len(errors)} | p95: {p95:.1f}ms | {sent/DURATION:,.0f} msg/s")

import { check } from 'k6';
import ws from 'k6/ws';
import { Trend, Counter } from 'k6/metrics';

const msgLatency = new Trend('ws_msg_latency', true);
const dropCount  = new Counter('ws_drop_count');

export const options = {
  stages: [
    { duration: '2m', target: 1000 }, { duration: '5m', target: 10000 },
    { duration: '10m', target: 10000 }, { duration: '2m', target: 0 },
  ],
  thresholds: { 'ws_msg_latency': ['p(95)<100'], 'ws_drop_count': ['count<10'] },
};

export default function () {
  const res = ws.connect('wss://market.bank.th/feed', {}, function(sock) {
    sock.on('open', () => sock.send(JSON.stringify({ type: 'subscribe', channel: 'SET' })));
    sock.on('message', (data) => {
      const msg = JSON.parse(data);
      if (msg.server_ts) msgLatency.add(Date.now() - msg.server_ts);
    });
    sock.on('close', () => dropCount.add(1));
    sock.setTimeout(() => sock.close(), 600_000);
  });
  check(res, { 'WS connected': (r) => r && r.status === 101 });
}

# ── Unary RPC: Core Account Service ─────────────────────────────
ghz --insecure \
  --proto ./proto/account.proto \
  --call  bank.account.AccountService/GetBalance \
  --data  '{"account_id": "ACC-001"}' \
  --rps 5000 --duration 300s --connections 100 --concurrency 1000 \
  --timeout 200ms --format pretty core-banking-svc:9090

# Expected: p95: 45ms | DeadlineExceeded: 0.09% ✓ (threshold <0.1%)