Updated on 2025-08-19 GMT+08:00

KafkaProducer

Introduction to KafkaProducer

This system keyword can be used to test Kafka producers.

Parameter

Mandatory

Type

Default Value

Description

Broker

Yes

String

127.0.0.1:9093

IP address of a Kafka instance

Topic

Yes

String

-

Topic of a Kafka message

Message

Yes

String

-

Body of each Kafka message

SASL Username

No

String

-

Kafka SASL username

SASL Password

No

String

-

Kafka SASL password

Truststore

No

File

-

Kafka client certificate

Truststore Password

No

String

-

Password of the Kafka client certificate

Kafka Authentication Description

  • Authentication mode: If you configure SASL Username, SASL Password, Truststore, and Truststore Password in the KafkaProducer keyword, and the Kafka uses the SASL_SSL authentication protocol for encrypted data transmission, then client authentication is required.
  • No authentication mode: If you do not configure SASL Username, SASL Password, Truststore, and Truststore Password in the KafkaProducer keyword, and the Kafka uses the default SASL_PLAINTEXT protocol, then no encryption or authentication mechanism will be used. In this mode, the communication between the client and server is in plaintext, and security cannot be guaranteed.

KafkaProducer Response

Status: success

Parameter

Type

Description

Body

String

Value returned by the KafkaProducer API

KafkaProducer Response Example

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

Default Checkpoint

Name

Expected Value

Result

Success

KafkaProducer Usage Example

Configure parameters to send a Kafka message.