ReadyAPI - Adding assertions on Received Data from Kafka subscribe event

Question

I am using readyapi to read some events from our Kafka queue. I have successfully connected, Subcribed, to the queue and I see events coming in while running some tests which creates events on that topic.&nbsp;The problem is that I cannot do assertion on the events I see coming in. In my other REST test cases I use the GetData functionality to read some value. But here for the KAFKA when I open e.g ScriptAssertion and navigate to the Subscribe test step (again which I see has received events) the ReadyAPI does not give me anything to select... The ADD button is disabled!&nbsp;Then I test it on my REST test cases and it works fine.. REST test step-&gt;Response-&gt;add assertion-&gt;Select "script assertion"-&gt;right-click-&gt;GetData-&gt;navigate to the test step-&gt;Response-&gt;Select wanted value-&gt;Done&nbsp;KAFKA test step-&gt;Response (Received data)-&gt;add assertion-&gt;Select "script assertion"-&gt;right-click-&gt;GetData-&gt;navigate to the test step-&gt;cannot do anything more... No parameter to select and the ADD button is disabled.... But the events are visible, received!&nbsp;Any suggestions, how can I automatically get the received data?Checked property transfer as well but neither that works.&nbsp;Readyapi version 3.9.2&nbsp; &nbsp;(also tested on 3.9.1 same issue)

tneuschwanger · Answer

Hello amirse&nbsp;I don't know the answer, and it has been a long time ago that I dealt with messaging systems...&nbsp;&nbsp;Things that I remember biting me were:-time to life of the message.&nbsp; Could that have expired in your case and it is therefore no longer available on the queue or topic for the GetData to see?-read once then delete.&nbsp; Could that have happened in your case and it is therefore no longer available on the queue or topic for the GetData to see?&nbsp;... just throwing out a couple of things to think about.&nbsp;Sorry,Todd

amirse · Answer

Hi,thank you for your suggestions. I have managed to modify the groovy script found in the below ticket to get datahttps://community.smartbear.com/t5/SoapUI-Open-Source/Need-groovy-script-to-read-messages-from-kafka-topic/td-p/196019&nbsp;However I really hope smartbear will come back to us with a solution on how to get that response with the "GetData" functionality.&nbsp;&nbsp;Until they do here is the code I have modified that now works for me.&nbsp;Hope it will help other peopleimport org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;

import java.util.Arrays;
import java.util.Properties;

log.info("*************************************************************************")
log.info("                                      TOPIC NAME    ")
log.info("*************************************************************************")

//SAVE RECEIVED DATA
def tsuite1 = testRunner.testCase.testSuite.project.getTestSuiteByName("TEST SUITE NAME");
def tcase1= tsuite1.getTestCaseByName("TEST CASE NAME");
db = tcase1.testSteps['Data Source'].dataSource.gridModel
int row =  testRunner.testCase.testSteps['Data Source'].currentRow
def guid = "ABC12345DEF"

//KAFKA SETTINGS
String topic = "MY-TOPIC-NAME"
Properties properties = new Properties();
properties.put("group.id", "test");
properties.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
properties.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
properties.put("security.protocol","SSL");
properties.put("ssl.keystore.password", "XXX");
properties.put("bootstrap.servers", "XXX:6667");
properties.put("ssl.key.password", "XXX");
properties.put("ssl.truststore.password", "XXX");
properties.put("ssl.truststore.location", "C:\MyCertificates\certificate.jks");
properties.put("ssl.keystore.location", "C:\MyCertificates\certificate.jks");
//properties.put("session.timeout.ms", "10000");
properties.put("max.poll.records", "5");

KafkaConsumer&lt;String, String&gt; consumer = new KafkaConsumer&lt;&gt;(properties);
consumer.subscribe(Arrays.asList(topic));
long t = System.currentTimeMillis();
long end = t + 9000;
while (System.currentTimeMillis()&lt;end){
	log.info("START READING")
	ConsumerRecords&lt;String, String&gt; records = consumer.poll(200);
	for (ConsumerRecord&lt;String, String&gt; record : records){
		log.info("key = " + record.key())
		log.info("value = " + record.value());

if(record.value().contains(guid)){
			log.info("found data")
			db.setValueAt(topic, row, 1);
			db.setValueAt(guid, row, 2);
		}
	}
	log.info("STOP READING")
}
  consumer.close();

barrow · Answer

3 years later have we made any progress as to why this is still not possible using the API test step? I would like to leverage the existing ReadyAPI test step and not have to use a work around like the code shown above.

Forum Discussion

Recent Discussions

AbstractTestRunner error

Smart Assertion default of "Received Data"

Vulnerable jetty files

Related Content

Buzzword bingo from new subscribers

ReadyApi JSONPath match assertion with Wildcard

ReadyAPI header exists assertion failures