Accessing Poll results as dictionary about robotframework-confluentkafkalibrary HOT 3 CLOSED

Hi @ZephyrusMB,
could you please show me how do you produce data to kafka?

I will look at this tomorrow but three things came up on my mind:

1. please try to use decode_format https://robooo.github.io/robotframework-ConfluentKafkaLibrary/#Poll (then it should be string) or maybe you can try to load it as json (with json lib, json.loads() )
2. The Evaluate looks strange I think it's converted to unicode e.g. u'xyz' to RF but in python you should get simple bytes:

>>> a = b'{"key":"vaue","key2":"value","key3":3}'
>>> print(type(a))

So you are trying to read keys from bytes which will not work + even from unicode it doesn't work.

3. you can try convert it to dict with https://robotframework.org/robotframework/latest/libraries/Collections.html#Convert%20To%20Dictionary

Note: if you want to use basic confluent kafka Message object you can set only_value=False in https://robooo.github.io/robotframework-ConfluentKafkaLibrary/#Poll

from robotframework-confluentkafkalibrary.

Hi @robooo
Unluckily i have no chance to show you how data to kafka are produced, the test is a read-only so far (if you allow me this expression).

Thank you very much for your help then what I did after your reply is the following:

1. Decoded the message as utf-8
2. Converted the string as Json with JSONlibrary
3. Accessed the value inside the JSON

${messages}= Poll group_id=${group_id} max_records=3 decode_format=utf_8
${json} Convert String to JSON ${messages}[0]
${jsonValue} Get value from JSON ${json} $.key

converting the object as a dictionary is the tried N.3 I showed in my previous message, ended up in this error TypeError: cannot convert dictionary update sequence element #0 to a sequence

Thank you again for your help, now it is suppose to be much easier to work with the datas as JSON.

from robotframework-confluentkafkalibrary.

Example will be in documentation da3a7f3

from robotframework-confluentkafkalibrary.