또 다른 리눅스 셸에서는 스트리밍 프로그램의 결과를 확인한다. 다음과 같이 kafka-console-consumer.sh 스크립트를 실행하면 metrics 토픽으로 유입된 메시지를 볼 수 있다(이 셸에서도 카프카의 bin 디렉터리를 PATH에 추가해야 한다).

$ kafka-console-consumer.sh --zookeeper localhost:2181 --topic metrics
TOP5CLIENTS, List(62, 2, 92, 25, 19) 
SELLS, List(12) 
BUYS, List(20) 
TOP5STOCKS, List(CHK, DOW, FB, SRPT, ABX) 
TOP5CLIENTS, List(2, 62, 87, 52, 45) 
TOP5STOCKS, List(FB, CTRE, AU, PHG, EGO) 
SELLS, List(28) 
BUYS, List(21) 
SELLS, List(37) 
BUYS, List(12) 
TOP5STOCKS, List(FB, CTRE, SDLP, AU, NEM) 
TOP5CLIENTS, List(14, 2, 81, 43, 31)

 

제대로 결과를 출력했다. 우리의 스파크 스트리밍 프로그램은 지표 계산 결과를 카프카로 무사히 전송한다.