我正在为kafka代理搜索一个简单的事件/数据流生成器，以便在hadoop框架的流工具上运行一些性能测试。到目前为止还没有找到合适的。它应该能够在很短的时间（毫秒）内发送大量（几乎相等的）消息。谢谢！
cwdobuhd1#
您可以使用kafka 0.9+附带的kafka-producer-perf-test.sh工具。它允许您生成给定大小的大量消息。这个工具只是一个生产者，允许您发送一批消息和收集统计数据。在我们的性能测试中，我们使用这个工具（或者我们自己的性能生成器，但这与此类似），当我们想要增加负载时，我们在不同的主机上并行运行几个示例。
1条答案
按热度按时间cwdobuhd1#
您可以使用kafka 0.9+附带的kafka-producer-perf-test.sh工具。它允许您生成给定大小的大量消息。这个工具只是一个生产者，允许您发送一批消息和收集统计数据。
在我们的性能测试中，我们使用这个工具（或者我们自己的性能生成器，但这与此类似），当我们想要增加负载时，我们在不同的主机上并行运行几个示例。