问题描述
Azure Event Hub支持 kafka，所以为了测试消息生产者所在环境与Azure Event Hub之间发送消息的性能如何，特别使用 kafka 官方测试生产者，消费者的性能工具 ：
- kafka-producer-perf-test.bat
- kafka-consumer-perf-test.bat
(.bat 表示为Windows系统中运行， .sh表示在Linux系统中远行)
这些文件包含在kafka软件包中：https://kafka.apache.org/downloads
实现步骤
第一步：解压 kafka ，在bin/windows文件夹中，找到 kafka-producer-perf-test.bat 文件
第二步：通过CMD，执行 ” kafka-producer-perf-test.bat --help ” 来查看指令的参数
在本文中测试Azure Event Hub 需要配置的参数有：
1） --topic ：指定消息需要发送到哪一个Event Hub (注意：kafka的Topic对应于Azure Event Hub Namespace下的一个Event Hub)
2）--num-records ： 指定发送多少条消息到Event Hub中
3）--record-size ：设置每一条消息的大小，单位是 bytes （1个字节）
4）--throughput ：-1 表示不设置吞吐量的限制(throttle maximum message throughput to *approximately* THROUGHPUT messages/sec. Set this to -1 to disable throttling.)
5）--producer.config ： 设置生产者的服务器配置信息，设置Event Hub Namespace的Connection String
## 基本设置 bootstrap.servers=*****.servicebus.chinacloudapi.cn:9093 security.protocol=SASL_SSL sasl.mechanism=PLAIN sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="Endpoint=sb://*****.servicebus.chinacloudapi.cn/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=***************";
注：sasl.jaas.config中的connection string内容，需要从Azure Event Hub 的 Shared access policie 获取。把以上内容保存在一个单独文件中，如 kafka-producer-perf-test-config.txt
第三步：启动测试命令，然后查看输出结果
下面的命令表示：发送50万条1kb的数据到 test_topic 中
kafka-producer-perf-test.bat --topic test_topic --num-records 500000 --record-size 1024 --throughput -1 --producer.config kafka-producer-perf-test-config.txt
测试的结果显示：
3720 records sent, 743.6 records/sec (0.73 MB/sec), 47367.8 ms avg latency, 49685.0 ms max latency.
表示已经发送 3720条数据，每秒发送743条，平均延迟在47秒，最大延迟49秒 (>_< 测试机器网速堪忧啊！)
同理，使用（kafka-consumer-perf-test.bat）也可以测试消费端的性能。
参考资料
Kafka : https://kafka.apache.org