zookeeper storm zeromq 예제

목표

1. 각각 실행.

2. zookeeper이랑 storm 연결

3. zeromq는 데이터 입력값으로 가져올 수 있다.

 

 

nano conf/zoo.cfg

server.1=127.0.0.1:2888:3888
추가

 

추후작업

conf/zoo.cfg 파일에

dataDir=/path/to/zookeeper/data

을 했었던것을 기억하고 있을 것이다.

/path/to/zookeeper/data에 touch 등을 이용해 myid파일을 만든다.

$touch myid

$nano myid
1

server.1=127.0.0.1:2888:3888

위에 1로 설정했기때문에 이 아이디를 myid에도 넣는다.

server.myid=hostname:피어별통신을 위한포트:리더선출을 위한 포트

 

확인

$cat dataDir/myid

 

스톰 실행

$storm nimbus &
$storm ui &
numbus 와 ui를 &(백그라운드작업)로 실행한다.

storm supervisor

 

 

웹페이지에서 상태를 확인하자

storm/storm.yaml 문서에서

ui.port를 8744로 설정했기에 127.0.0.1:8744 에 접속해 현재 상태를 확인한다.

 

---

storm 과 zeromq 연결하기

 

 

 

 

 

• 기타