Apache Kafka

Messaging

kafka://

Produce and fetch against Kafka with one operation per request. The broker is the URL authority and the topic its path (kafka://broker:9092/topic). Ships the pure-Rust rskafka client — no librdkafka, no C toolchain.

Install

$ loadr plugin install kafka

kafka.yaml

plugins:
  - name: kafka          # resolves kafka:// at runtime

scenarios:
  producers:
    executor: constant-vus
    vus: 5
    duration: 15s
    flow:
      - request:
          url: kafka://broker.example.com:9092/loadr-demo
          plugin:
            operation: produce
            key: "vu-${vu}"
            value: "event from vu ${vu} iter ${iteration}"
          assert:
            - { type: status, equals: 1 }   # 1 = ok, 0 = client error

thresholds:
  kafka_req_duration: [ "p(95)<1s" ]
  kafka_reqs: [ "count>0" ]

Metrics: kafka_reqs · kafka_req_duration · kafka_msgs.

Read the docs → Watch the demo

Install the plugin, then produce and fetch messages against Apache Kafka — see demo #19.

A runtime plugin, never in the binary

Installing pulls a per-platform driver from the signed index, verifies its SHA-256 and checks its ABI before it ever loads. Remove it any time with loadr plugin remove kafka.

← Redis All plugins RabbitMQ →