안녕하세요 질문있습니다.!

8 asked

0

• 노트북의 H2나 로컬 MySQL로 잰 값은 참고용입니다. 실제 Mysql의 경우 저장되어 있는 레코드 수에 따라서도 편차가 있습니다.

• k6로 테스트할 API를 높은 속도로 때리면서 Kafka consumer lag을 봅니다. lag이 계속 늘면 컨슈머가 못 따라가는 것이고, lag이 일정하게 유지되는 최대 발급 속도가 시스템 전체의 처리량입니다.

0

안녕하세요!! 답변 드립니다.

1. 재는 대상은 컨슈머가 아니라 "DB 쓰기 경로"입니다

k6는 HTTP를 두드리는 도구라 Kafka 컨슈머를 직접 재지 못합니다. 대신 컨슈머가 DB에 하는 일(주문 INSERT + 재고 UPDATE, 같은 트랜잭션)을 그대로 실행하는 테스트용 엔드포인트를 하나 만들고, 그걸 k6로 두드립니다. 그러면 "이 DB가 이 쓰기를 초당 몇 건까지 받아주는가"가 나오고, 그 숫자가 컨슈머 쓰로틀의 상한입니다.

2. VU 고정이 아니라 "초당 요청 수를 계단식으로 올리는" 실행기를 씁니다

constant-vus는 응답이 느려지면 요청 속도도 같이 느려져서 한계가 안 보입니다. ramping-arrival-rate로 50 → 100 → 200 → 400 → 800 req/s 계단을 올리면서 어느 계단에서 꺾이는지 봅니다.

import http from 'k6/http';

export const options = {
  scenarios: {
    find_knee: {
      executor: 'ramping-arrival-rate',
      startRate: 50, timeUnit: '1s',
      preAllocatedVUs: 50, maxVUs: 500,
      stages: [
        { target: 50,  duration: '1m' },
        { target: 100, duration: '1m' },
        { target: 200, duration: '1m' },
        { target: 400, duration: '1m' },
        { target: 800, duration: '1m' },
      ],
    },
  },
  thresholds: { http_req_duration: ['p(95)<200'], http_req_failed: ['rate<0.01'] },
};

export default function () {
  http.post('http://localhost:8080/test/settle',
    JSON.stringify({ orderId: `${__VU}-${__ITER}`, qty: 1 }),
    { headers: { 'Content-Type': 'application/json' } });
}