처리 지연을 어떻게 구현해야하나요?
안녕하세요 강사님 !
kafka:
consumer:
max-poll-records: 5이것 저것 찾아보다가 한번에 가져오는 레코드의 양을 줄이는 옵션이 있어서 적용해봤습니다.
그래서 처리되는 속도는 비슷하더라구요.
컨슈머가 속도를 설정해서 천천히 이벤트를 확인하고 싶은데
강사님이 말씀하신 걸 적용하려면 어떤 옵션을 줘야하나요?
답변 2
0
안녕하세요, 인프런 AI 인턴입니다.
kamser님, kafka의 컨슈머가 이벤트를 천천히 확인하고 싶으시다면 처리 지연을 구현하는 방법 중 하나로 fetch.min.bytes와 fetch.max.wait.ms 옵션을 조정할 수 있습니다. fetch.min.bytes 옵션은 컨슈머가 fetch 요청을 할 때 가져오는 데이터의 최소 크기를 설정하는 옵션이고, fetch.max.wait.ms 옵션은 서버가 최소 데이터 양을 충족시키기 위해 대기하는 최대 시간을 설정하는 옵션입니다. 이 두 옵션을 조정함으로써 컨슈머가 데이터를 가져오는 속도를 늦출 수 있습니다. 더 깊이있는 설정이나 최적화를 원하시면 Kafka 문서를 참조하거나, Kafka를 운영한 경험이 있는 커뮤니티의 조언을 구하는 것도 좋겠습니다.
이 외에도 특정 상황에 따라 좀 더 세밀한 조정이 필요할 수 있으니, Kafka 공식 문서인 https://kafka.apache.org/documentation/#operations 를 참고해 보시는 것을 추천드립니다.
ApplyService와 Consumer서비스의 db공유?
0
54
2
consumer가 topic을 전부 사용하기 전에 사용자에게는 쿠폰이 발급된것으로 확인하는 과정에서 발생가능한 문제.
0
73
1
쿠폰에 관련되어서 좀 더 참고할만한 자료가 있을까요?
0
83
2
흐름정리 제가 이해한게 맞나요?
0
70
2
안되서 스트레스 받아요
-2
108
2
프로젝트 진행할때 모듈로 추가하는 이유가 궁금합니다!
0
183
2
Redis 활용하기 문제점 해결하기 부분이 이해가 잘 안됩니다...
0
212
1
카프카를 도입하고 난 뒤 로그로 보여지는 장점을 발견하지 못하고 있습니다.
0
167
2
키생성 방식에 따른 성능
0
165
2
사용자 동선에 대한 트랜잭션 문의
0
134
2
강사님 강의를 듣고 실제 프로젝트에서 이벤트 응모 시스템을 만들어 봤습니다.
0
209
1
쿠폰 발급 개수 제한
0
181
2
ApplyService 의 총 처리 시간이 궁금합니다.
0
154
1
쿠폰 생성 에러 처리에 관해서 질문이 있습니다.
0
224
2
마지막에 하신 테스트 자체는 실패하는 게 맞는거죠??
0
274
2
안녕하세요 질문 있습니다!
0
293
1
쿠폰 발급 유저 흐름에 대한 질문
0
307
2
수량 조절에 대한 질문이 있습니다.
0
230
2
kafka Producer 실행 중 에러 시 redis count 정합성 이슈
0
398
2
test 과정에서 오류가 발생합니다.
0
381
1
도커 환경설정에 대해서
0
267
2
Redis의 INCR 사용 해도 Race condition이 잡히지 않는 문제
0
593
1
consumer 모듈
0
321
2
카프카 토픽 생성오류
0
381
2