我试图按照下面的apachekafka文章运行性能测试
参考文献:
https://engineering.linkedin.com/kafka/benchmarking-apache-kafka-2-million-writes-second-three-cheap-machines
在测试中链接:https://gist.github.com/jkreps/c7ddb4041ef62a900e6c
但当我运行时:
bin/kafka-run-class.sh org.apache.kafka.clients.tools.ProducerPerformance test7 50000000 100 -1 acks=1 bootstrap.servers=localhost:9092 buffer.memory=67108864 batch.size=8196
显示错误:
Error: Could not find or load main class org.apache.kafka.clients.tools.ProducerPerformance
是关于Kafka的版本吗?或者我需要从其他地方下载课程?
我的org.apache.kafka.clients.tools.producerperformance类在哪里?请建议。。
2条答案
按热度按时间7qhs6swi1#
我认为在运行此命令之前,您需要先构建项目。。您可以使用构建工具,例如
sbt
在他们的官方网站上有记载4c8rllxm2#
的包名称
ProducerPerformance
已从更改为org.apache.kafka.clients.tools
至org.apache.kafka.tools
.有关更多详细信息,请查看我的答案,以查找可能重复的问题。