apiVersion: batch/v1
kind: Job
metadata:
  name: message-source
  namespace: my-namespace
spec:
  template:
    spec:
      containers:
      - name: message-source
        image: docker.io/aliok/message-source:latest
        env:
          - name: KAFKA_HOST
            value: my-cluster-kafka-bootstrap.kafka:9092
          - name: KAFKA_TOPIC
            value: topic-a
          - name: MESSAGE_COUNT
            value: '20000'
          - name: MESSAGE_FREQUENCY
            value: '100' # send a message every 100 ms
      restartPolicy: Never
