Middleware: KafkaConsumer

This system keyword can be used to test Kafka consumers.

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
Consumer Group	Yes	String	-	Kafka message consumer group
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

Status: success

Parameter	Type	Description
Body	String	Value returned by the KafkaConsumer API

{
  "message" : [{
    "offset" : 102130,
    "value" : "kafka message 1"
  }, {
    "offset" : 102131,
    "value" : "kafka message 2"
  }]
}

Name	Expected Value
Result	Success

Configure parameters to receive a Kafka message.

Parent topic: System Keywords

Thank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.

The system is busy. Please try again later.

Which of the following issues have you encountered?

Content is inconsistent with the product UI

Unclear descriptions

Lack of examples or code

Incorrect steps

Can't find what I need

Lack of best practices

Feedback (optional)

0/500

Select at least one type of issue, and enter your comments or suggestions.

Enter a maximum of 500 characters.

Submit Cancel

For any further questions, feel free to contact us through the chatbot.