wip

scripts/cli/confluent-kafka-region-list.txt

@@ -0,0 +1,99 @@
+Name/Region
+Bahrain(me-south-1)/me-south-1
+Belgium(europe-west1)/europe-west1
+Calgary(ca-west-1)/ca-west-1
+Canada(ca-central-1)/ca-central-1
+CapeTown(af-south-1)/af-south-1
+Dallas(us-south1)/us-south1
+Dammam(me-central2)/me-central2
+Delhi(asia-south2)/asia-south2
+Doha(me-central1)/me-central1
+Doha(qatarcentral)/qatarcentral
+Dubai(uaenorth)/uaenorth
+Finland(europe-north1)/europe-north1
+Frankfurt(eu-central-1)/eu-central-1
+Frankfurt(europe-west3)/europe-west3
+Frankfurt(germanywestcentral)/germanywestcentral
+Gävle(swedencentral)/swedencentral
+HongKong(ap-east-1)/ap-east-1
+HongKong(asia-east2)/asia-east2
+HongKong(eastasia)/eastasia
+Hyderabad(ap-south-2)/ap-south-2
+Iowa(centralus)/centralus
+Iowa(us-central1)/us-central1
+Ireland(eu-west-1)/eu-west-1
+Ireland(northeurope)/northeurope
+Jakarta(ap-southeast-3)/ap-southeast-3
+Jakarta(asia-southeast2)/asia-southeast2
+Johannesburg/southafricanorth
+(southafricanorth)/
+LasVegas(us-west4)/us-west4
+London(eu-west-2)/eu-west-2
+London(europe-west2)/europe-west2
+London(uksouth)/uksouth
+LosAngeles(us-west2)/us-west2
+Madrid(europe-southwest1)/europe-southwest1
+Melbourne(ap-southeast-4)/ap-southeast-4
+Melbourne/australia-southeast2
+(australia-southeast2)/
+MexicoCentral(mexicocentral)/mexicocentral
+Milan(eu-south-1)/eu-south-1
+Milan(europe-west8)/europe-west8
+Milan(italynorth)/italynorth
+Montreal/northamerica-northeast1
+(northamerica-northeast1)/
+Mumbai(ap-south-1)/ap-south-1
+Mumbai(asia-south1)/asia-south1
+N.Virginia(us-east-1)/us-east-1
+N.Virginia(us-east4)/us-east4
+Netherlands(europe-west4)/europe-west4
+Netherlands(westeurope)/westeurope
+NewSouthWales/australiaeast
+(australiaeast)/
+Ohio(us-east-2)/us-east-2
+Oregon(us-west-2)/us-west-2
+Oregon(us-west1)/us-west1
+Osaka(ap-northeast-3)/ap-northeast-3
+Osaka(asia-northeast2)/asia-northeast2
+Oslo(norwayeast)/norwayeast
+Paris(eu-west-3)/eu-west-3
+Paris(europe-west9)/europe-west9
+Paris(francecentral)/francecentral
+Phoenix(westus3)/westus3
+Pune(centralindia)/centralindia
+S.Carolina(us-east1)/us-east1
+SaltLakeCity(us-west3)/us-west3
+Santiago(southamerica-west1)/southamerica-west1
+SaoPaulo(southamerica-east1)/southamerica-east1
+SaoPaulostate(brazilsouth)/brazilsouth
+Seoul(ap-northeast-2)/ap-northeast-2
+Seoul(asia-northeast3)/asia-northeast3
+Seoul(koreacentral)/koreacentral
+Singapore(ap-southeast-1)/ap-southeast-1
+Singapore(asia-southeast1)/asia-southeast1
+Singapore(southeastasia)/southeastasia
+Spain(eu-south-2)/eu-south-2
+Spain(spaincentral)/spaincentral
+Stockholm(eu-north-1)/eu-north-1
+Sydney(ap-southeast-2)/ap-southeast-2
+Sydney(australia-southeast1)/australia-southeast1
+SãoPaulo(sa-east-1)/sa-east-1
+Taiwan(asia-east1)/asia-east1
+TelAviv(il-central-1)/il-central-1
+TelAviv(me-west1)/me-west1
+Texas(southcentralus)/southcentralus
+Tokyo(ap-northeast-1)/ap-northeast-1
+Tokyo(asia-northeast1)/asia-northeast1
+Tokyo(japaneast)/japaneast
+Toronto(canadacentral)/canadacentral
+Toronto/northamerica-northeast2
+(northamerica-northeast2)/
+Turin(europe-west12)/europe-west12
+UAE(me-central-1)/me-central-1
+Virginia(eastus)/eastus
+Virginia(eastus2)/eastus2
+Warsaw(europe-central2)/europe-central2
+Washington(westus2)/westus2
+Zurich(eu-central-2)/eu-central-2
+Zurich(europe-west6)/europe-west6
+Zurich(switzerlandnorth)/switzerlandnorth

scripts/cli/playground

@@ -8571,7 +8571,7 @@ function set_profiles() {
 
   # Check if ENABLE_FLINK is set to true
   profile_flink=""
-  if [ -z "$ENABLE_FLINK" ] 
+  if [ -z "$ENABLE_FLINK" ]
   then
     log "🛑 Starting services without Flink"
     playground state del flags.ENABLE_FLINK
@@ -14338,7 +14338,6 @@ playground_run_command() {
         unset 'options[29]'
       fi
 
-
       missing_env=""
       declare -a missing_env_list=()
 
@@ -18966,7 +18965,7 @@ playground_debug_heap_dump_command() {
           docker exec $container jmap -dump:live,format=b,file=/tmp/${filename} 1
       else
           log "🎯 Taking heap dump (without live option) on container ${container}"
-          docker exec $container jmap -dump:live,format=b,file=/tmp/${filename} 1
+          docker exec $container jmap -dump:format=b,file=/tmp/${filename} 1
       fi
       if [ $? -eq 0 ]
       then

scripts/cli/src/commands/run.sh

@@ -215,6 +215,12 @@ then
   export ENABLE_CONTROL_CENTER=true
 fi
 
+if [[ -n "$enable_flink" ]]
+then
+  array_flag_list+=("--enable-flink")
+  export ENABLE_FLINK=true
+fi
+
 if [[ -n "$enable_conduktor" ]]
 then
   array_flag_list+=("--enable-conduktor")
@@ -806,6 +812,12 @@ then
     else
       unset 'options[28]'
     fi
+    if [ ! -z $ENABLE_FLINK ]
+    then
+      unset 'options[20]'
+    else
+      unset 'options[29]'
+    fi
 
     missing_env=""
     declare -a missing_env_list=()
@@ -1015,6 +1027,19 @@ then
       interactive_enable_c3=""
     fi
 
+    if [[ $res == *"$MENU_ENABLE_FL"* ]]
+    then
+      array_flag_list+=("--enable-flink")
+      export ENABLE_FLINK=true
+      interactive_enable_flink="true"
+    fi
+    if [[ $res == *"$MENU_DISABLE_FL"* ]]
+    then
+      array_flag_list=("${array_flag_list[@]/"--enable-flink"}")
+      unset ENABLE_FLINK
+      interactive_enable_flink=""
+    fi
+
     if [[ $res == *"$MENU_ENABLE_RP"* ]]
     then
       array_flag_list+=("--enable-rest-proxy")
@@ -1312,6 +1337,14 @@ then
     fi
   fi
 
+  if [ "$interactive_enable_flink" == "true" ]
+  then
+    if [[ -n "$force_interactive_repro" ]]
+    then
+      force_enable --enable-flink ENABLE_FLINK
+    fi
+  fi
+
   if [ "$interactive_enable_conduktor" == "true" ]
   then
     if [[ -n "$force_interactive_repro" ]]