카프카 api stat, metric 지표를 보기 위한 burrow(https://github.com/linkedin/Burrow/wiki/HTTP-Endpoint)라는 오픈 소스 툴이 있다.
kafka에서 사용하고 싶은 http endpoint를 보고 호출한다.
https://github.com/linkedin/Burrow/wiki/HTTP-Endpoint#request-endpoints
예)
http://burrow.google.io:8000/v3/kafka/mycluster/topic/logs
{"error":false,"message":"topic offsets returned","offsets":[152223734586,152224559773,152224774276,152224723888,152224644847,152224641838,152224508250,152224383547,152215033727,152215053018,152214434045,152214530227,152215253175,152214990582,152215431432,152213601661,152215273301,152215092394,152214795862,152215123946,152215194674,152215391037,152214877453,152215137734,152215680569,152215360097,152214928462,152215484025,152214933673,152214661665,152214049830,152215021533,152215748420,152214945335,152215126831,152215051384,152214863230,152214966710,152215634739,152214820473,152215165668,152215071434,152214866458,152214865355,152214934334,152214662023,152214830751,152214573022,152215197587,152214836785],"request":{"url":"/v3/kafka/mycluster/topic/logs","host":"burrow-google"}}
'kafka' 카테고리의 다른 글
| kafka connect Creation of database history topic failed, please create the topic manually / TimeoutException 에러 (0) | 2019.03.19 |
|---|---|
| stream stream-join 정보와 mjoin (0) | 2019.03.02 |
| [kafka] enable.auto.commit , auto.commit.interval.ms (0) | 2018.10.22 |
| [kafka] lag 생긴다고 파티션 추가하는 것에 대해 (0) | 2018.08.31 |
| kafka에서 retention.ms 수정하는 방법 (0) | 2018.07.09 |
