我相信kafka-consumer-perf-test.sh脚本适用于每个Kafka安装，它应该足以满足您的用例，请参阅Performance testing Kafka Wiki page了解更多细节。
该脚本可以使用OS Process Sampler与JMeter集成
如果您正在谈论使用JMeter从故障中阅读消息-它可以通过任何JSR 223测试元素完成
1.获取Kafka Java Client
1.将库沿着和依赖项放入JMeter类路径
1.重新启动JMeter以获取库
1.将实现从Kafka主题中阅读消息的代码放入JSR 223 Sampler示例片段中：

props.put('bootstrap.servers', '192.168.99.100:9092')
props.put('group.id', 'foo')
props.put('enable.auto.commit', 'true')
props.put('auto.commit.interval.ms', '1000')
props.put('session.timeout.ms', '30000')
props.put('key.deserializer',
        'org.apache.kafka.common.serialization.StringDeserializer')
props.put('value.deserializer',
        'org.apache.kafka.common.serialization.StringDeserializer')
def consumer = new org.apache.kafka.clients.consumer.KafkaConsumer<String, String>(props)
def topic = 'sometopic'

consumer.subscribe(Arrays.asList(topic))
log.info('Subscribed to topic ' + topic)

while (true) {
    def records = consumer.poll(100)
    records.each { record ->
        log.info('Received message: ' + record.value())
    }
}

更多信息请参阅：

• Apache Kafka - How to Load Test with JMeter