컨슈머 주요 옵션

https://kafka.apache.org/documentation/#consumerconfigs

bootstrap.servers

카프카 클러스터에 최초 연결설정을 위한 클러스터 노드 목록

fetch.min.bytes

한번에 가져올 수 있는 최소 데이터 크기(byte). 인입 데이터가 적다면 최소 데이터 크기를 만족할때까지 대기한다. 대기하는 시간은 fetch.min.bytes 로 설정한다. (디폴트: 1)

group.id

컨슈머가 속한 컨슈머 그룹을 식별하는 ID값. 컨슈머가 subscribe() 메서드 또는 오프셋 관리하는데 사용한다

enable.auto.commit

백그라운드로 주기적으로 오프셋을 커밋할지 여부 (디폴트: true)

auto.offset.reset

초기 오프셋이 없거나 현재 오프셋이 더 이상 서버에 존재하지 않는 경우(해당 데이터가 삭제된 경우) 수행할 작업

fetch.max.bytes

힌번에 가져올 수 있는 최대 데이터 크기

request.timeout.ms

요청에 대해 응답을 기다리는 최대 시간을 설정. 타임아웃이 발생하면 필요한 경우 다시 요청을 시도한다. 그래도 실패할 경우 예외를 던짐 (디폴트: 30000)

session.timeout.ms