# flink-job-instance.yaml
apiVersion: flink.logicamp.dev/v1alpha1
kind: FlinkJob
metadata:
  name: my-flink-job
spec:
  key: word-count
  name: "Word Count Example"
  entryClass: "tech.logicamp.logiline.FacilityEnrichment"
  parallelism: 1
  jarRef: "lcr.logicamp.tech/logiline/facility-enrichment:1.0.0"
  jarPullSecret: "lcr-registry-creds"
  # args accepts two formats:
  #   Map (recommended):
  args:
    kafka-host: kafka.pg-release:9092
    kafka-group-id: batch-sales-config-dedup-processor
  #   List (also valid):
  #   args:
  #     - "--kafka-host"
  #     - kafka.pg-release:9092
  #     - "--kafka-group-id"
  #     - batch-sales-config-dedup-processor
  flinkConfiguration:
    taskmanager.numberOfTaskSlots: "1"
    parallelism.default: "1"