je_load_density.wrapper.user_template.kafka_user_template

Kafka user template.

Each task entry:

{"method": "produce", "topic": "events", "value": "hello",
 "key": "session-1", "name": "publish"}
{"method": "consume", "topic": "events", "timeout": 5,
 "expect": "hello"}
{"method": "flush"}

Functions

set_wrapper_kafka_user(user_detail_dict, ...)

Classes

KafkaUserWrapper(*args, **kwargs)

Locust user that produces/consumes against a Kafka cluster.

class je_load_density.wrapper.user_template.kafka_user_template.KafkaUserWrapper(*args: Any, **kwargs: Any)

Bases: User

Locust user that produces/consumes against a Kafka cluster.

host = 'localhost:9092'

run_tasks() → None

wait_time = 0.1

je_load_density.wrapper.user_template.kafka_user_template.set_wrapper_kafka_user(user_detail_dict: Dict[str, Any], **kwargs) → type