基於hdp的kafka使用
阿新 • • 發佈：2019-02-04
1.建立topic，進入kafka目錄
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2.驗證topic
./kafka-topics.sh --list --zookeeper localhost:2181
3.傳送訊息
./kafka-console-producer.sh --broker-list localhost:6667 --topic test
4.接收訊息
./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
5.下載KafkaOffsetMonitor包，進行kafka客戶端驗證
java -Xms512M -Xmx512M -Xss1024K -XX:PermSize=256m -XX:MaxPermSize=512m -cp KafkaOffsetMonitor-assembly-0.2.0.jar com.quantifind.kafka.offsetapp.OffsetGetterWeb --zk 172.16.1.171:2181,172.16.1.172:2181,172.16.1.173:2181,172.16.1.174:2181,172.16.1.175:2181 --port 8086 --refresh 10.seconds --retain 7.days