在CodeArts TestPlan接口脚本中调用KafkaProducer关键字
KafkaProducer简介
该系统关键字支持对Kafka的生产者进行测试。
参数 |
是否必选 |
参数类型 |
默认值 |
描述 |
---|---|---|---|---|
Broker |
是 |
String |
127.0.0.1:9093 |
Kafka实例ip地址。 |
Topic |
是 |
String |
- |
Kafka消息的主题。 |
Message |
是 |
String |
- |
Kafka每一条发送的消息主体。 |
SASL Username |
否 |
String |
- |
Kafka SASL 权限认证配置用户名。 |
SASL Password |
否 |
String |
- |
Kafka SASL 权限认证配置密码。 |
Truststore |
否 |
File |
- |
Kafka客户端证书。 |
Truststore Password |
否 |
String |
- |
Kafka客户端证书密码。 |
KafkaProducer响应
状态:成功
参数 |
参数类型 |
描述 |
---|---|---|
Body |
String |
KafkaProducer接口返回值。 |
KafkaProducer响应示例
{ "result" : "send message to kafka success.", "status" : "ok" }
默认检查点
名称 |
预期值 |
---|---|
结果 |
成功 |
KafkaProducer使用示例
填写参数,发送Kafka消息: