2016-06-29 2 views
1
알 수없는

나는 종종 소비자가오프셋과 카프카의 소비자 지연 (새로운 소비자 API를 통해 생성)을

GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER 
G.AB_KAFF, T.AB_KAFF, 0, 3, 6, 3, consumer-2 
G.AB_KAFF, T.AB_KAFF, 1, 8, 11, 3, consumer-2 
현재 오프셋됩니다 오프셋 한 한
알 수없는 이전 소비자로 설정 지연의 설정 및 지연 카프카있는 문제를보고하고로 설정 내가 몇 일 후에 다시 소비자를 가입

오프셋 및 지연이 내가 주제에서 전체 소비자 그룹을 탈퇴하고 있기 때문에 카프카가 소비자에 대한 이전의 오프셋을 제거하고 알 수없는

GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER 
G.AB_KAFF, T.AB_KAFF, 0, unknown, 7, unknown, consumer-2 
G.AB_KAFF, T.AB_KAFF, 1, unknown, 11, unknown, consumer-2 

로 설정?

답변

4

kafka는 주제에서 전체 소비자 그룹 가입을 취소 했으므로 해당 소비자에 대한 이전 오프셋을 제거합니까?

네, 맞습니다. offsets.retention.minutes=1440 (24 hours) 기본값은 24 시간입니다.
오프셋에 대한 로그 보존 기간 (분) 토픽