References
CPS-1613 Explore How to Test Kafka in the CSITs
Assumptions
# | Issue | Notes | Decisions |
---|---|---|---|
1 |
Issues & Decisions
# | Issue | Notes | Decisions |
---|---|---|---|
1 |
Overview
Can Robot Framework test Kafka clusters and events?
- In the latest version of Robot Framework (6.0.2), there is no support for Kafka Event Streaming.
Is there any third-party library that would aid in this?
- ConfluentKafkaLibrary is a Robot Framework library to verify Kafka Event Streaming.
- Robotframework-ConfluentKafkaLibrary
Issues
In the current implementation of ConfluentKafkaLibrary, the consumer module connects to Kafka cluster from the port "9092".
Consumer init
def __init__( self, server='127.0.0.1', port='9092', topics='', group_id=None, only_value=True, **kwargs ):
Whereas, CPS's kafka container expose its port from "19092"
CPS's kafka container
kafka: image: confluentinc/cp-kafka:6.2.1 container_name: kafka ports: - "19092:19092"
In order to solve this conflict, the current port has been changed to 9092 in docker-compose.yml