updating kafka streams console to use productized version

ansible/roles_ocp_workloads/ocp4_workload_summit_2024_cloud_native_camel/files/kafka-user.yaml

@@ -1,7 +1,7 @@
 apiVersion: kafka.strimzi.io/v1beta2
 kind: KafkaUser
 metadata:
-  name: console-kafka-user1
+  name: console-kafka-user
   labels:
     strimzi.io/cluster: kafka
 spec:

ansible/roles_ocp_workloads/ocp4_workload_summit_2024_cloud_native_camel/tasks/install_kafka-console.yml

@@ -37,17 +37,44 @@
     loop_var: user
 
 # Install Console
-- name: Check Kafka Console ClusterRole
+- name: Evaluate Console Operator
   kubernetes.core.k8s:
     validate_certs: '{{ verify_tls }}'
     state: present
-    resource_definition: "{{ lookup('file', 'kafka-console-cr.yaml') }}"
+    kind: Subscription
+    api_version: operators.coreos.com/v1alpha1
+    definition:
+      metadata:
+        name: amq-streams-console
+        namespace: openshift-operators
+      spec:
+        channel: alpha
+        installPlanApproval: Automatic
+        name: amq-streams-console
+        source: redhat-operators
+        sourceNamespace: openshift-marketplace
 
-- name: Check Kafka Console Template
+- name: Wait for AMQ Streams Console operator to be running
+  kubernetes.core.k8s_info:
+    validate_certs: '{{ verify_tls }}'
+    api_version: v1
+    kind: Pod
+    namespace: openshift-operators
+    label_selectors:
+      - app.kubernetes.io/instance=amq-streams-console-operator-v2.8.0-13
+    field_selectors:
+      - status.phase=Running
+  register: r_streams_pod
+  retries: 10
+  delay: 10
+  until: r_streams_pod.resources | list | length == 1
+
+- name: Check Console cr
   kubernetes.core.k8s:
     validate_certs: '{{ verify_tls }}'
     state: present
-    resource_definition: "{{ lookup('template', 'kafka-console-template.yaml.j2') }}"
+    namespace: '{{ user }}-{{ globex_ns_suffix }}'
+    resource_definition: "{{ lookup('template', 'console.yml.j2') }}"
   loop: "{{ users }}"
   loop_control:
-    loop_var: user
+    loop_var: user

ansible/roles_ocp_workloads/ocp4_workload_summit_2024_cloud_native_camel/templates/console.yml.j2

@@ -0,0 +1,16 @@
+apiVersion: console.streamshub.github.com/v1alpha1
+kind: Console
+metadata:
+  name: {{ user }}-console
+spec:
+  hostname: streams-console-{{ user }}-{{ globex_ns_suffix }}.{{ route_subdomain }}
+  kafkaClusters:
+    - name: kafka
+      namespace: {{ user }}-{{ globex_ns_suffix }}
+      listener: plain 
+      properties:
+        values: [] 
+        valuesFrom: [] 
+      credentials:
+        kafkaUser:
+          name: console-kafka-user