Forum Discussion

Occasional Contributor

4 months ago

Unable to read Kafka received messages using MessageExchange

Hi All,

I have subscribed to a topic and i receive messages in the topic.

When i add a script assertion to this step using MessageExchange like

def response = messageExchange.getResponse()
log.info response

I am getting the following error

Error in assertion script of the [Receive Message] test step: Cannot invoke method getResponse() on null object

Am i missing to add something here?Can i read kafka received messages using messageExchange.

Kindly help.

abhinaykumar15
Occasional Contributor
4 months ago
This way also does not work.I had tried earlier but it was giving null.
Humashankar
Champion Level 3
4 months ago
Hi abhinaykumar15

You're on the right track using MessageExchange to access messages in ReadyAPI, but there's a refined difference when working with Kafka compared to traditional requests and responses.

The "null object" error occurs because messageExchange.getResponse() is designed for retrieving responses in a request-response flow, which doesn't apply to subscribing to a Kafka topic.

Try using a Groovy Script assertion in your "Receive Message" test step to access the received Kafka messages. Specifically, utilize messageExchange.getMessageBodies() to retrieve a list of messages, allowing you to effectively handle the Kafka message exchange.

Hope this helps - Happy to help further!!
Thank you very much and have a great one!
Warm regards
Humashankar
Champion Level 3
4 months ago
Hi abhinaykumar15 - Thanks for the update, let me try some other options and will get back.
abhinaykumar15
Occasional Contributor
3 months ago
Hi All,
From ReadyAPI 3.54 kafka received messages can be read using groovy script and can be validated.
def data = context.expand( '${Teststep-name#data}' )
log.info(data)