How anandh88/openshift-cfk-gitops-lilly works
This repository defines a GitOps-managed Confluent and Flink streaming platform, with observability and a sample claims-processing workload. The principal workload reads raw claims from Kafka, deduplicates them, maintains per-bucket counts, and writes processed claims back to Kafka. The tree shows bootstrap, platform, workload, and monitoring subsystems; their detailed wiring is not available in the supplied excerpts, so those relationships are omitted or marked unverified. The sampled job source documents its internal stages and Kafka configuration.
Main entry points: app-of-apps.yaml Argo CD apps · ClaimsProcessorJob.java Claims processor · confluent-platform Confluent services · flink-application.yaml Flink application
Components 16
GitOps Bootstrap
- Cluster bootstrap
bootstrap - Argo CD apps
apps/app-of-apps.yaml
Streaming Platform
- Confluent operator
base/confluent-operator - Confluent services
base/confluent-platform - Kafka cluster
base/confluent-platform/kafka.yaml - Raw claims topic
base/confluent-platform/flink-claims-topics.yaml - Processed claims topic
base/confluent-platform/flink-claims-topics.yaml
Flink Workload
- Flink operator
apps/flink-kubernetes-operator-app.yaml - Flink deployment
base/flink-jobs/flink-deployment.yaml - Flink application
base/flink-jobs/flink-application.yaml - Claims processor
flink-jobs/claims-processor/src/main/java/com/statefarm/flink/ClaimsProcessorJob.java
Observability
- Metrics collection
base/observability - Grafana dashboards
base/observability/grafana
Environment Overlays
- Local overlay
overlays/local/kustomization.yaml - Production overlay
overlays/prod/kustomization.yaml
Other components
- Platform operator
Connections 14
- Platform operator → Cluster bootstrap: configures
- Cluster bootstrap → Argo CD apps: sets up
- Argo CD apps → Confluent operator: deploys
- Argo CD apps → Confluent services: deploys
- Argo CD apps → Flink operator: deploys
- Argo CD apps → Flink application: deploys
- Argo CD apps → Metrics collection: deploys
- Claims processor → Raw claims topic: reads
flink-jobs/claims-processor/src/main/java/com/statefarm/flink/ClaimsProcessorJob.java - Claims processor → Processed claims topic: writes
flink-jobs/claims-processor/src/main/java/com/statefarm/flink/ClaimsProcessorJob.java - Claims processor → Flink application: configured by
- Flink deployment → Flink application: runs
- Metrics collection → Grafana dashboards: visualizes
- Local overlay → Confluent services: customizes
- Production overlay → Confluent services: customizes