Library    RobotKafkaLibrary.Producer
Library    RobotKafkaLibrary.Consumer
 
*** Test Cases ***
Test producer topic test publish message1
    ${RESULT} =     Publish  {broker-ip}:{port}   {topic}   {message}
    log    ${RESULT}
    Log to console   ${RESULT}

Test consumer topic test subscribe message1
    ${MSG} =     Subscribe  {broker-ip}:{port}   {topic}   {option-timeout}
    log    ${MSG}
    Log to console   ${MSG}