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 |
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.
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.
For any further questions, feel free to contact us through the chatbot.
Chatbot