Mockintosh: mocks for microservice environments - Part 7: Asynchronous Kafka Actors

01.yaml

services:
- name: Kafka Mocks
  type: kafka
  address: "{{ env 'KAFKA_ADDR' 'localhost:9092' }}"
  actors: []

02.yaml

management:
  port: 8080
services:
- name: Kafka Mocks
  type: kafka
  address: "{{ env 'KAFKA_ADDR' 'localhost:9092' }}"
  actors:
    - name: Simplest Validating Consumer
      consume:
        queue: topic1

03.yaml

services:
- name: Kafka Mocks
  type: kafka
  address: "{{ env 'KAFKA_ADDR' 'localhost:9092' }}"
  actors:
    - name: Complex Validating Consumer
      consume:
        queue: topic1
        key: "{{ regEx 'prefix-(.*)' }}"
        value: "{{ regEx '(.*)-suffix' }}"
        headers:
          client-id: "{{ regEx '[0-9]+' }}"

04.yaml

management:
  port: 8080
services:
- name: Kafka Mocks
  type: kafka
  address: "{{env 'KAFKA_ADDR' 'localhost:9092'}}"
  actors:
    - name: templated-producer
      produce:
        queue: templated-producer
        key: "prefix-{{ random.uuid4 }}"
        value: "{{ fake.name }}"
        headers:
          name: templated
          constant: constant-value
          timestamp: "{{ date.timestamp }}"
          counter: "{{ counter 'kafkaCounter' }}"
          fromFile: "@templates/example.txt"

05.yaml

management:
  port: 8080
services:
- name: Kafka Mocks
  type: kafka
  address: "{{env 'KAFKA_ADDR' 'localhost:9092'}}"
  actors:
    - name: Consumer for the Templated Producer
      consume:
        queue: templated-producer
    - name: templated-producer
      produce:
        queue: templated-producer
        key: "prefix-{{ random.uuid4 }}"
        value: "{{ fake.name }}"
        headers:
          name: templated
          constant: constant-value
          timestamp: "{{ date.timestamp }}"
          counter: "{{ counter 'kafkaCounter' }}"
          fromFile: "@templates/example.txt"

06.yaml

services:
- name: Kafka Mocks
  type: kafka
  address: "{{ env 'KAFKA_ADDR' 'localhost:9092' }}"
  actors:
    - produce:
        create: true
        queue: topic2
        key: key2
        value: value2
        headers:
          hdr2: val2
      delay: 2
      limit: 100

07.yaml

services:
- name: Kafka Mocks
  type: kafka
  address: "{{ env 'KAFKA_ADDR' 'localhost:9092' }}"
  actors:
    - produce:
        create: true
        queue: topic2
        key: key2
        value: value2
        headers:
          hdr2: val2
      delay: 2

08.yaml

services:
- name: Kafka Mocks
  type: kafka
  address: "{{ env 'KAFKA_ADDR' 'localhost:9092' }}"
  actors:
    - consume:
        queue: topic3
      delay: 3
      produce:
        queue: topic4
        key: key4
        value: "value4 and {{ consumed.key }} {{ consumed.value }} {{ consumed.headers.hdr3 }}"
        headers:
          hdr4: val4

example.txt

Random integer: {{ fake.random_int min=10 max=90 step=5 }}