kafka命令行

1、启动
cd /home/hadoop/kafka_2.12-0.10.2.1/bin
nohup ./zookeeper-server-start.sh ./config/zookeeper.properties & 启动zookeeper
nohup ./kafka-server-start.sh ./config/server.properties & 启动kafka broker

2、检查kafka是否启动成功，通过jps查看jps是否启动成功

3、通过创建一个topic来测试是否能成功运行，随便选择一个节点运行

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic user_ippv

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic result_total_pvuv_min

Created topic “test”.
4、生产者
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic user_ippv

5、消费者
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic result_total_pvuv_min --from-beginning

在此推荐一个好用的kafka tools: https://www.kafkatool.com/download.html