更新时间:2024-10-11 GMT+08:00

在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客户端证书密码。

KafkaConsumer响应

状态:成功

参数

参数类型

描述

Body

String

KafkaConsumer接口返回值。

KafkaConsumer响应示例

{
  "message" : [{
    "offset" : 102130,
    "value" : "kafka message 1"
  }, {
    "offset" : 102131,
    "value" : "kafka message 2"
  }]
}

默认检查点

名称

预期值

结果

成功

KafkaConsumer使用示例

填写参数接受kafka消息: