Kafka JMX를 이용하여 모니터링 하기!(테스트중)

 

아파치 카프카의 도큐먼트에 따라 Jconsole을 이용하여 해당 브로커가 관리하는 토픽에 유입되는 메시지 수를 파악할 수 있다. InPerSec라고 해서 초당 메시지 수라고 생각했으나, 초당이 아닌 전체 메시지 수를 확인할 수 있다.

테스트를 위해 프로듀서를 생성하여 생성한 토픽(song-topic)으로 100개의 메시지를 보내는 프로그램을 실행하고,

이를 Jconsole에서 확인하였다.

 

kafka.apache.org/090/documentation.html#monitoring

Apache Kafka

 

 

 

 

해당 브로커로 유입되는 초당 메시지 수를 확인하고, 토픽별로 확인을 할 수 있는지 다시 테스트를 진행했다.

새로운 토픽 song-topic2로 위와 같은 방법으로 메시지를 300개 전송하고, 다시 메트릭을 실행해보았다.

Jconsole에는 새로운 토픽과 그에 해당하는 정보들이 업데이트되었다.

그리고 프로그램으로 메트릭 결과를 가져온 결과, song-topic의 메시지 수 100 + song-topic2의 메시지 수 300개의 합을 볼 수 있다.

토픽별 메시지 유입 수가 아닌 브로커별 메시지 유입 수(토픽 메시지 수의 합)으로 확인하였다.

 

 

 

브로커별 메시지 수가 아닌, 토픽별 메시지 수를 확인하고 싶은 경우, 토픽 명을 지정해주면 된다.

 

 

근데 나는 전체 메시지의 수가 아닌, 초당 메시지 유입 수를 알고싶다. 어떻게 해야 할까?

저기 나오는 OneMinuteRate가 어떻게 계산되는건지 잘 모르겠다.

초당 메시지 유입 수를 알고 싶은 경우, 1초에 한번씩 메트릭을 실행시켜서 늘어나는 수를 알 수 있겠지만 뭔가 더 좋은 방법이 없을까

 

 

 

-value가 0이어야 정상동작이다.

kafka.server:type=ReplicaManager,name=UnderReplicatedPartitions

 

 

오늘은 여기까지.