stackabletech · adwk67 · Jul 15, 2025 · Jul 15, 2025
diff --git a/demos/nifi-kafka-druid-earthquake-data/create-nifi-ingestion-job.yaml b/demos/nifi-kafka-druid-earthquake-data/create-nifi-ingestion-job.yaml
@@ -63,7 +63,7 @@ data:
     import urllib3
 
     # As of 2022-08-29 we cant use "https://nifi:8443" here because <h2>The request contained an invalid host header [<code>nifi:8443</code>] in the request [<code>/nifi-api</code>]. Check for request manipulation or third-party intercept.</h2>
-    ENDPOINT = f"https://nifi-node-default-0.nifi-node-default.{os.environ['NAMESPACE']}.svc.cluster.local:8443" # For local testing / developing replace it, afterwards change back to f"https://nifi-node-default-0.nifi-node-default.{os.environ['NAMESPACE']}.svc.cluster.local:8443"
+    ENDPOINT = f"https://nifi-node-default-0.nifi-node-default-headless.{os.environ['NAMESPACE']}.svc.cluster.local:8443" # For local testing / developing replace it, afterwards change back to f"https://nifi-node-default-0.nifi-node-default.{os.environ['NAMESPACE']}.svc.cluster.local:8443"
     USERNAME = "admin"
     PASSWORD = open("/nifi-admin-credentials-secret/admin").read()
 

diff --git a/demos/nifi-kafka-druid-earthquake-data/setup-superset.yaml b/demos/nifi-kafka-druid-earthquake-data/setup-superset.yaml
@@ -55,7 +55,7 @@ data:
     import logging
     import requests
 
-    base_url = "http://superset-node-default:8088" # For local testing / developing replace it, afterwards change back to http://superset-node-default:8088
+    base_url = "http://superset-node:8088" # For local testing / developing replace it, afterwards change back to http://superset-node:8088
     superset_username = open("/superset-credentials/adminUser.username").read()
     superset_password =  open("/superset-credentials/adminUser.password").read()
 

diff --git a/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/druid_1.png b/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/druid_1.png
diff --git a/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/minio_1.png b/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/minio_1.png
diff --git a/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/nifi_1.png b/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/nifi_1.png
diff --git a/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/nifi_2.png b/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/nifi_2.png
diff --git a/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/nifi_3.png b/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/nifi_3.png
diff --git a/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/nifi_4.png b/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/nifi_4.png
diff --git a/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/nifi_5.png b/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/nifi_5.png
diff --git a/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/superset_1.png b/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/superset_1.png
diff --git a/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/superset_4.png b/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/superset_4.png
diff --git a/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/superset_7a.png b/docs/modules/demos/images/nifi-kafka-druid-earthquake-data/superset_7a.png
diff --git a/...afka-druid-earthquake-data/superset_7.png → ...fka-druid-earthquake-data/superset_7b.png b/...afka-druid-earthquake-data/superset_7.png → ...fka-druid-earthquake-data/superset_7b.png
diff --git a/docs/modules/demos/pages/nifi-kafka-druid-earthquake-data.adoc b/docs/modules/demos/pages/nifi-kafka-druid-earthquake-data.adoc
diff --git a/stacks/nifi-kafka-druid-superset-s3/druid.yaml b/stacks/nifi-kafka-druid-superset-s3/druid.yaml
@@ -7,7 +7,6 @@ spec:
   image:
     productVersion: 33.0.0
   clusterConfig:
-    listenerClass: external-unstable
     zookeeperConfigMapName: druid-znode
     metadataStorageDatabase:
       dbType: postgresql
@@ -29,10 +28,14 @@ spec:
                   secretClass: druid-s3-credentials
         baseKey: data
   brokers:
+    roleConfig:
+      listenerClass: external-unstable
     roleGroups:
       default:
         replicas: 1
   coordinators:
+    roleConfig:
+      listenerClass: external-unstable
     roleGroups:
       default:
         replicas: 1
@@ -63,6 +66,8 @@ spec:
             memory:
               limit: 16Gi
   routers:
+    roleConfig:
+      listenerClass: external-unstable
     roleGroups:
       default:
         replicas: 1

diff --git a/stacks/nifi-kafka-druid-superset-s3/kafka.yaml b/stacks/nifi-kafka-druid-superset-s3/kafka.yaml
@@ -20,6 +20,8 @@ spec:
       - authenticationClass: kafka-client-tls
   brokers:
     config:
+      bootstrapListenerClass: external-stable
+      brokerListenerClass: external-stable
       resources:
         storage:
           logDirs:

diff --git a/stacks/nifi-kafka-druid-superset-s3/nifi.yaml b/stacks/nifi-kafka-druid-superset-s3/nifi.yaml
@@ -9,11 +9,12 @@ spec:
   clusterConfig:
     authentication:
       - authenticationClass: nifi-admin-credentials
-    listenerClass: external-unstable
     sensitiveProperties:
       keySecret: nifi-sensitive-property-key
       autoGenerate: true
   nodes:
+    roleConfig:
+      listenerClass: external-stable
     config:
       resources:
         cpu:

diff --git a/stacks/nifi-kafka-druid-superset-s3/superset.yaml b/stacks/nifi-kafka-druid-superset-s3/superset.yaml
@@ -10,7 +10,7 @@ spec:
     credentialsSecret: superset-credentials
     mapboxSecret: superset-mapbox-api-key
   nodes:
-    config:
+    roleConfig:
       listenerClass: external-unstable
     roleGroups:
       default: