更新时间：2023-03-27 GMT+08:00
中间件类—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消息：
父主题： 接口自动化用例系统关键字
