要给出“Apache Kafka性能测试工具”的解决方案，需要分为两个方面：选择性能测试工具和编写代码示例。

1. 选择性能测试工具：

   • Apache Kafka自带的工具：Kafka自带了一些工具，如kafka-producer-perf-test.sh和kafka-consumer-perf-test.sh，可以用于测试生产者和消费者的性能。这些工具可以在Kafka的安装目录的bin文件夹中找到。
   • Apache JMeter：JMeter是一款功能强大的开源性能测试工具，可以用于测试Kafka的性能。它支持模拟大量的并发用户和生成大量的消息，用于测试Kafka的吞吐量和延迟等指标。
   • Apache Bench：Apache Bench是Apache HTTP服务器的压力测试工具，也可以用于测试Kafka的性能。通过编写简单的脚本，可以模拟多个并发请求，并测量响应时间和吞吐量等指标。

2. 编写代码示例：

   • 使用kafka-producer-perf-test.sh工具：可以使用以下命令测试生产者的性能：

     ./kafka-producer-perf-test.sh --topic test_topic --num-records 1000000 --record-size 100 --throughput 1000000 --producer-props bootstrap.servers=localhost:9092
     

     这个命令将在test_topic主题上生成100万条大小为100字节的消息，每秒发送100万条消息。可以根据需要修改参数。

   • 使用JMeter：可以使用JMeter的Kafka插件来进行性能测试。首先，需要安装JMeter，并下载Kafka插件。然后，可以创建一个线程组，在线程组中添加一个Kafka Producer Sampler，配置生产者的相关属性，如主题、消息大小、吞吐量等。最后，可以运行测试计划，JMeter将模拟产生消息并测量性能指标。

   • 使用Apache Bench：可以编写一个简单的脚本来测试Kafka的性能。以下是一个示例脚本：

     import subprocess
     
     def run_test():
         command = "ab -n 100000 -c 100 -k -p payload.json -T application/json http://localhost:9092/topics/test_topic"
         process = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE)
         process.wait()
     
     if __name__ == "__main__":
         run_test()
     

     这个脚本使用Apache Bench发送100,000个并发请求，每个请求包含一个名为payload.json的JSON文件，将其发送到test_topic主题。

以上是关于“Apache Kafka性能测试工具”的解决方案，你可以根据自己的需求选择适合的工具和编写代码示例。