kafka：集群搭建位置：10.0.xx.xx蔗坯，/home/bjsasc/soft/service/kafka_2.12-2.3.0/deployment
創(chuàng)建 TOPIC
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic testTopicDup3
查看 topic 列表：
bin/kafka-topics.sh --list --zookeeper localhost:2181
產(chǎn)生消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopicDup3
消費消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testTopicDup3 --from-beginning
查看描述 TOPICS 信息
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic testTopicDup3
創(chuàng)建topic：
分區(qū)為6测蘑，復(fù)制因子為1趴樱，數(shù)據(jù)的保留時間為1小時：
bin/kafka-topics.sh --create --topic ttopic-p1-r1-60min --partitions 6 --replication-factor 1 --config retention.ms=86400000 --bootstrap-server 10.0.xx:9092
查看分區(qū)
bin/kafka-topics.sh --list --bootstrap-server 10.0.xx:9092
壓測：生產(chǎn)者擒抛，300萬條數(shù)據(jù)蔬充，每條消息的大小為1KB羽莺，-throughput設(shè)為-1時表示消息會盡快生成灭袁。
bin/kafka-producer-perf-test.sh --topic ttopic-p1-r1-60min --throughput -1 --num-records 3000000 --record-size 1024 --producer-props acks=all bootstrap.servers=10.0.xx:9092
壓測：消費者
bin/kafka-consumer-perf-test.sh --topic ttopic-p1-r1-60min --broker-list 10.0.xx:9092 --messages 3000000
刪除topic：
bin/kafka-topics.sh --delete --topic ttopic-p1-r1-60min --bootstrap-server 10.0.xx:9092
