Skip to content

Commit 4d30f82

Browse files
committed
adapted to new releases / crds / nifi version
1 parent 6916ca8 commit 4d30f82

File tree

2 files changed

+54
-16
lines changed

2 files changed

+54
-16
lines changed

modules/tutorials/attachments/s3-kafka.xml

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@
9393
<bundle>
9494
<artifact>nifi-record-serialization-services-nar</artifact>
9595
<group>org.apache.nifi</group>
96-
<version>1.15.0</version>
96+
<version>1.16.3</version>
9797
</bundle>
9898
<comments/>
9999
<descriptors>
@@ -379,7 +379,7 @@
379379
<bundle>
380380
<artifact>nifi-record-serialization-services-nar</artifact>
381381
<group>org.apache.nifi</group>
382-
<version>1.15.0</version>
382+
<version>1.16.3</version>
383383
</bundle>
384384
<comments/>
385385
<descriptors>
@@ -594,7 +594,7 @@
594594
<bundle>
595595
<artifact>nifi-record-serialization-services-nar</artifact>
596596
<group>org.apache.nifi</group>
597-
<version>1.15.0</version>
597+
<version>1.16.3</version>
598598
</bundle>
599599
<comments/>
600600
<descriptors>
@@ -738,7 +738,7 @@
738738
<bundle>
739739
<artifact>nifi-aws-nar</artifact>
740740
<group>org.apache.nifi</group>
741-
<version>1.15.0</version>
741+
<version>1.16.3</version>
742742
</bundle>
743743
<config>
744744
<bulletinLevel>WARN</bulletinLevel>
@@ -1017,7 +1017,7 @@
10171017
<bundle>
10181018
<artifact>nifi-aws-nar</artifact>
10191019
<group>org.apache.nifi</group>
1020-
<version>1.15.0</version>
1020+
<version>1.16.3</version>
10211021
</bundle>
10221022
<config>
10231023
<bulletinLevel>WARN</bulletinLevel>
@@ -1258,7 +1258,7 @@
12581258
<bundle>
12591259
<artifact>nifi-kafka-2-6-nar</artifact>
12601260
<group>org.apache.nifi</group>
1261-
<version>1.15.0</version>
1261+
<version>1.16.3</version>
12621262
</bundle>
12631263
<config>
12641264
<bulletinLevel>WARN</bulletinLevel>
@@ -1577,7 +1577,7 @@
15771577
<bundle>
15781578
<artifact>nifi-standard-nar</artifact>
15791579
<group>org.apache.nifi</group>
1580-
<version>1.15.0</version>
1580+
<version>1.16.3</version>
15811581
</bundle>
15821582
<config>
15831583
<bulletinLevel>WARN</bulletinLevel>

modules/tutorials/pages/end-to-end_data_pipeline_example.adoc

Lines changed: 47 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -105,9 +105,9 @@ helm install nifi-operator stackable-stable/nifi-operator
105105
----
106106
====
107107

108-
=== Deploying Kafka and NiFi
108+
=== Deploying ZooKeeper
109109

110-
To deploy Kafka and NiFi you can now apply the cluster configuration. You'll also need to deploy ZooKeeper, since both Kafka and NiFi depend on it. Run the following command in the console to deploy and configure all three services.
110+
Since both Kafka and NiFi depend on Apache ZooKeeper, we will create a ZooKeeper cluster first.
111111

112112
[source,bash]
113113
kubectl apply -f - <<EOF
@@ -117,7 +117,7 @@ kind: ZookeeperCluster
117117
metadata:
118118
name: simple-zk
119119
spec:
120-
version: 3.8.0-stackable0.1.0
120+
version: 3.8.0-stackable0.7.1
121121
servers:
122122
roleGroups:
123123
default:
@@ -126,6 +126,14 @@ spec:
126126
kubernetes.io/os: linux
127127
replicas: 1
128128
config: {}
129+
EOF
130+
131+
=== Deploying Kafka and NiFi
132+
133+
To deploy Kafka and NiFi you can now apply the cluster configuration. Run the following command in the console to deploy and configure all three services.
134+
135+
[source,bash]
136+
kubectl apply -f - <<EOF
129137
---
130138
apiVersion: zookeeper.stackable.tech/v1alpha1
131139
kind: ZookeeperZnode
@@ -374,13 +382,26 @@ Now that the Operator and Dependencies are set up, you can deploy the Druid clus
374382

375383
[source]
376384
kubectl apply -f - <<EOF
385+
---
386+
apiVersion: secrets.stackable.tech/v1alpha1
387+
kind: SecretClass
388+
metadata:
389+
name: druid-s3-credentials
390+
spec:
391+
backend:
392+
k8sSearch:
393+
searchNamespace:
394+
pod: {}
395+
---
377396
apiVersion: v1
378397
kind: Secret
379398
metadata:
380399
name: druid-s3-credentials
400+
labels:
401+
secrets.stackable.tech/class: druid-s3-credentials
381402
stringData:
382-
accessKeyId: minioAccessKey
383-
secretAccessKey: minioSecretKey
403+
accessKey: minioAccessKey
404+
secretKey: minioSecretKey
384405
EOF
385406

386407
And now the cluster definition:
@@ -401,13 +422,30 @@ spec:
401422
port: 5432
402423
user: druid
403424
password: druid
404-
s3:
405-
endpoint: http://minio:9000
406-
credentialsSecret: druid-s3-credentials # <3>
425+
ingestion:
426+
s3connection:
427+
inline:
428+
host: http://minio
429+
port: 9000
430+
accessStyle: Path
431+
credentials:
432+
secretClass: druid-s3-credentials # <3>
407433
deepStorage:
408434
storageType: s3
409435
bucket: nytaxidata
410436
baseKey: storage
437+
deepStorage:
438+
s3:
439+
bucket:
440+
inline:
441+
bucketName: nytaxidata
442+
connection:
443+
inline:
444+
host: http://minio
445+
port: 9000
446+
accessStyle: Path
447+
credentials:
448+
secretClass: druid-s3-credentials # <3>
411449
brokers:
412450
configOverrides:
413451
runtime.properties:
@@ -484,7 +522,7 @@ kubectl port-forward svc/druid-nytaxidata-router 8888
484522

485523
Keep this command running to continue accessing the Router port locally.
486524

487-
The UI should now be reachable at http://localhost:8888 and should look like the screenshot below. Start with the Load Data option:
525+
The UI should now be reachable at http://localhost:8888 and should look like the screenshot below. Start with the "Load Data" and "New Spec" option:
488526

489527
image::end-to-end_data_pipeline_example/druid-main.png[Main Screen]
490528

0 commit comments

Comments
 (0)