# 在CodeArts TestPlan接口脚本中调用KafkaConsumer关键字
#### KafkaConsumer简介
该系统关键字支持对Kafka的消费者进行测试。
| 参数                  | 是否必选 | 参数类型   | 默认值            | 描述                    |
|:---|:---|:---|:---|:---|
| Broker              | 是    | String | 127.0.0.1:9093 | Kafka实例ip地址。          |
| Topic               | 是    | String | -              | Kafka消息的主题。           |
| Consumer Group      | 是    | String | -              | Kafka消息消费组。           |
| SASL Username       | 否    | String | -              | Kafka SASL 权限认证配置用户名。 |
| SASL Password       | 否    | String | -              | Kafka SASL 权限认证配置密码。  |
| Truststore          | 否    | File   | -              | Kafka客户端证书。           |
| Truststore Password | 否    | String | -              | Kafka客户端证书密码。         |
   
#### Kafka认证说明
- 认证模式：用户在KafkaProducer关键字配置了SASL Username、SASL Password、Truststore、Truststore Password参数，对接Kafka为有认证模式，使用认证协议SASL_SSL，提供了数据传输的加密，也能确保客户端的身份认证。
- 无认证模式：用户在KafkaProducer关键字没有配置了SASL Username、SASL Password、Truststore、Truststore Password参数，对接Kafka为无认证模式，使用默认协议PLAINTEXT，不使用任何加密或认证机制，在这种模式下，客户端与服务器之间的通信是明文的，不提供任何安全保障。
 
#### KafkaConsumer响应
状态：成功
| 参数   | 参数类型   | 描述                  |
|:---|:---|:---|
| Body | String | KafkaConsumer接口返回值。 |
   
#### KafkaConsumer响应示例
```
{
  "message" : [{
    "offset" : 102130,
    "value" : "kafka message 1"
  }, {
    "offset" : 102131,
    "value" : "kafka message 2"
  }]
}
```
#### 默认检查点
| 名称 | 预期值 |
|:---|:---|
| 结果 | 成功  |
   
#### KafkaConsumer使用示例
填写参数接受kafka消息：
![](https://support.huaweicloud.com/usermanual-testman/zh-cn_image_0000001964152705.png "点击放大")