基本指令

1.启动服务端

  1. bin/kafka-server-start.sh -daemon config/server.properties

2.关闭服务端

  1. bin/kafka-server-stop.sh stop

3.新建主题

  1. bin/kafka-topics.sh --zookeeper zk001:2181,zk002:2181,zk003:2181 --create --replication-factor 2 --partitions 3 --topic test

4.查看主题

  1. bin/kafka-topics.sh --list --zookeeper zk001:2181,zk002:2181,zk003:2181

5.启动生产者

  1. bin/kafka-console-producer.sh --broker-list bigdata001:9092,bigdata002:9092,bigdata003:9092 --topic test

6.启动消费者

  1. bin/kafka-console-consumer.sh --bootstrap-server bigdata001:9092,bigdata002:9092,bigdata003:9092 --topic test --from-beginning

压力测试

1.生产者压力测试

  1. bin/kafka-producer-perf-test.sh --topic test --num-records 500000 --record-size 200 --throughput -1 --producer-props bootstrap.servers=bigdata001:9092,bigdata002:9092,bigdata003:9092

2.消费者压力测试

  1. ./kafka-consumer-perf-test.sh --broker-list bigdata001:9092,bigdata002:9092,bigdata003:9092 --fetch-size 2000 --messages 500000 --topic test