인프런 커뮤니티 질문&답변

kamser님의 프로필 이미지
kamser

작성한 질문수

실습으로 배우는 선착순 이벤트 시스템

Consumer 사용하기

처리 지연을 어떻게 구현해야하나요?

해결된 질문

작성

·

264

0

안녕하세요 강사님 !

  kafka:
    consumer:
      max-poll-records: 5

이것 저것 찾아보다가 한번에 가져오는 레코드의 양을 줄이는 옵션이 있어서 적용해봤습니다.

 

그래서 처리되는 속도는 비슷하더라구요.

 

컨슈머가 속도를 설정해서 천천히 이벤트를 확인하고 싶은데

강사님이 말씀하신 걸 적용하려면 어떤 옵션을 줘야하나요?

답변 2

0

최상용님의 프로필 이미지
최상용
지식공유자

kamser 님 안녕하세요.
제가 말씀드린것 중에 어떤것을 적용하고 싶으신건지 말씀해주실 수 있으실까요 ?

0

안녕하세요, 인프런 AI 인턴입니다.
kamser님, kafka의 컨슈머가 이벤트를 천천히 확인하고 싶으시다면 처리 지연을 구현하는 방법 중 하나로 fetch.min.bytesfetch.max.wait.ms 옵션을 조정할 수 있습니다. fetch.min.bytes 옵션은 컨슈머가 fetch 요청을 할 때 가져오는 데이터의 최소 크기를 설정하는 옵션이고, fetch.max.wait.ms 옵션은 서버가 최소 데이터 양을 충족시키기 위해 대기하는 최대 시간을 설정하는 옵션입니다. 이 두 옵션을 조정함으로써 컨슈머가 데이터를 가져오는 속도를 늦출 수 있습니다. 더 깊이있는 설정이나 최적화를 원하시면 Kafka 문서를 참조하거나, Kafka를 운영한 경험이 있는 커뮤니티의 조언을 구하는 것도 좋겠습니다.

이 외에도 특정 상황에 따라 좀 더 세밀한 조정이 필요할 수 있으니, Kafka 공식 문서인 https://kafka.apache.org/documentation/#operations 를 참고해 보시는 것을 추천드립니다.

kamser님의 프로필 이미지
kamser

작성한 질문수

질문하기