kafka burrow

카프카 lag을 관리하기 위해서 

 

kafkaConsumer 객체로

 

lag을 실시간으로 확인하고싶다면,

 

elasticSearch나 influxdb에 넣은 뒤 grafana 대시보드를 통해 확인 가능.

 

consumer 단위에서 lag을 확인하면 -> 위험함

 

이유 ) 컨슈머 상태에 디펜던시가 걸리기 때문에

 

 

-> burrow를 제공함 ( gorang으로 제작됨)

 

3가지 특징 )

 

1) 멀티 카프카 클러스터 지원함.

 

 

2) sliding window을 통한 consumer의 status 확인 가능.

 

3) http api 제공.