Change Details

==== **User Story** > ==== As a platform engineer I need to deploy the PyFlink stream enrichment service to wikikube k8s ==== Why? So that it can be deployed to production to help us understand how well things scale ==== Done is: Existing code is enhanced to: [] Write to Kafka output [] Write to error output [] Metric collection ==== Dependencies: - Finalizing page content change schema ==== Expected Sub Tasks: [x] Deploy to YARN [x] Deploy to DSE [] Remove rc prefix for topic [x] Enable stream for all wikis [] Deploy Flink Operator to wikikube - T330507 [] Deploy to wikikube k8s - T330507

==== **User Story** > ==== As a platform engineer I need to deploy the PyFlink stream enrichment service to wikikube k8s ==== Why? So that it can be deployed to production to help us understand how well things scale ==== Dependencies: [x] Finalizing page content change schema ==== Expected Sub Tasks: [x] Deploy to YARN [x] Deploy to DSE [] Remove rc prefix from rc1.mediawiki.page_change topic [x] Enable stream for all wikis [] {T331282} [] Deploy flink-kubernetes-operator to wikikube - T330507 [] Deploy app to wikikube k8s - T330507

==== **User Story** > ==== As a platform engineer I need to deploy the PyFlink stream enrichment service to wikikube k8s ==== Why? So that it can be deployed to production to help us understand how well things scale ==== Done is: Existing code is enhanced to: [] Write to Kafka output [] Write to error output [] Metric collection ==== Dependencies: -[x] Finalizing page content change schema ==== Expected Sub Tasks: [x] Deploy to YARN [x] Deploy to DSE [] Remove rc prefix forrom rc1.mediawiki.page_change topic [x] Enable stream for all wikis [] {T331282} [] Deploy Flink Oflink-kubernetes-operator to wikikube - T330507 [] Deploy app to wikikube k8s - T330507