[KAFKA] Consumer 설정


[KAFKA] Consumer 설정

fetch.min.bytes 컨슈머가 브로커로부터 레코드를 얻어올 때 받는 데이터의 최소량을 지정 기본값은 1바이트 브로커가 컨슈머로부터 레코드 요청을 받았는데 새로 보낼 레코드의 양이 fetch.min.bytes보다 작을 경우, 브로커는 충분한 메시지를 보낼 수 있을 때까지 기다린 뒤 컨슈머에게 레코드를 보내준다. fetch.max.wait.ms 카프카가 컨슈머에게 응답하기 전에 데이터가 모일 때까지 얼마나 오래 기다릴 것인지를 결정한다. 기본값은 500 밀리초 카프카는 토픽에 컨슈머에게 리턴할 데이터가 부족할 경우 최소량 조건을 맞추기 위해 500밀리까지 기다리게 된다. fetch.max.wait.ms를 100밀리초, fetch.min.bytes를 1MB로 잡을 경우 카프카는 컨슈머로부터 읽기 요청을 받았을 때 리턴할 데이터가 1MB 이상 모이거나 100밀리초가 지나거나 두 조건 중 하나가 만족되는 대로 리턴하게 됨 fetch.max.bytes 컨슈머가 브로커를 폴링 할 때 카프...


#Consume #카프카 #카프카컨슈머

원문링크 : [KAFKA] Consumer 설정