更新时间:2025-08-22 GMT+08:00
分享

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

Kafka认证说明

  • 认证模式:用户在KafkaProducer关键字配置了SASL Username、SASL Password、Truststore、Truststore Password参数,对接Kafka为有认证模式,使用认证协议SASL_SSL,提供了数据传输的加密,也能确保客户端的身份认证。
  • 无认证模式:用户在KafkaProducer关键字没有配置了SASL Username、SASL Password、Truststore、Truststore Password参数,对接Kafka为无认证模式,使用默认协议PLAINTEXT,不使用任何加密或认证机制,在这种模式下,客户端与服务器之间的通信是明文的,不提供任何安全保障。

KafkaProducer响应

状态:成功

参数

参数类型

描述

Body

String

KafkaProducer接口返回值。

KafkaProducer响应示例

{
  "result" : "send message to kafka success.",
  "status" : "ok"
}

默认检查点

名称

预期值

结果

成功

KafkaProducer使用示例

填写参数,发送Kafka消息:

相关文档