運行Kafka監控KafkaOffsetMonitor(KafkaOffsetMonitor就是一個jarball),能夠參照下面的3個示例:java
java -cp KafkaOffsetMonitor-assembly-0.2.0.jar \app
com.quantifind.kafka.offsetapp.OffsetGetterWeb \spa
--zk zk-server1,zk-server2 \server
--port 8080 \ip
--refresh 10.seconds \kafka
--retain 2.daysit
java -cp KafkaOffsetMonitor-assembly-0.2.0.jar \test
com.quantifind.kafka.offsetapp.OffsetGetterWeb \監控
--zk rzsjtest01:2181 \ant
--port 7778 \
--refresh 5.seconds \
--retain 5.days
java -Xms512M -Xmx512M -Xss1024K -XX:PermSize=256m -XX:MaxPermSize=512m -cp KafkaOffsetMonitor-assembly-0.2.0.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk ip1:port,ip2:port --port 7778 --refresh 10.seconds --retain 7.daysx