如何写java程序代码测试kafka

我这里是使用的是，kafka自带的zookeeper。

以及关于kafka的日志文件啊，都放在默认里即/tmp下，我没修改。保存默认的

1、 [hadoop@sparksinglenode kafka_2.10-0.8.1.1]$ jps

2625 Jps

2、 [hadoop@sparksinglenode kafka_2.10-0.8.1.1]$ bin/zookeeper-server-start.sh config/zookeeper.properties

此刻，这时，会一直停在这，因为是前端运行。

另开一窗口，

3、 [hadoop@sparksinglenode kafka_2.10-0.8.1.1]$ bin/kafka-server-start.sh config/server.properties

也是前端运行。

kafka： 2.13-3.0.0

kafka-clients： 3.0.0

服务器配置：8C16G 200G硬盘

pom 引用3.0.0的客户端

java程序，有两个启动参数： kafka客户端数量、ack参数

3.0.0版本的kafka的测试用具内部只能启动1个客户端。

消息体长度 100Byte、 1000Byte、 10000Byte

消息体长度 100Byte、 1000Byte、 10000Byte

./kafka-producer-perf-test.sh --num-records 5000000 --record-size 1000 --topic KAFKA_TEST --throughput -1 --producer-props bootstrap.servers=xx.xx.xx.xx:9092

---