You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: docs/modules/nifi/pages/usage_guide/clustering.adoc
+1-1Lines changed: 1 addition & 1 deletion
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -33,7 +33,7 @@ This is enabled by setting the `spec.clusterConfig.zookeeperConfigMapName` to a
33
33
----
34
34
spec:
35
35
clusterConfig:
36
-
zookeeperConfigMapName: simple-nifi-znode
36
+
zookeeperConfigMapName: broken-nifi-znode
37
37
----
38
38
39
39
The ConfigMap needs to contain two keys: `ZOOKEEPER_HOSTS` containing the value being the ZooKeeper connection string, and `ZOOKEEPER_CHROOT` containing the ZooKeeper chroot.
Afterwards you need to expose the processor to the outside world.
25
25
26
26
For that to work, first create a Service object as follows.
27
-
In this guide, the NifiCluster is called `simple-nifi`. The name of the Nifi cluster must match the value of the `app.kubernetes.io/instance` as shown below.
27
+
In this guide, the NifiCluster is called `broken-nifi`. The name of the Nifi cluster must match the value of the `app.kubernetes.io/instance` as shown below.
28
28
29
29
[source,yaml]
30
30
----
31
31
apiVersion: v1
32
32
kind: Service
33
33
metadata:
34
-
name: simple-nifi-listen-http # Update according to NifiCluster name
34
+
name: broken-nifi-listen-http # Update according to NifiCluster name
35
35
spec:
36
36
type: ClusterIP
37
37
selector:
38
38
app.kubernetes.io/component: node
39
-
app.kubernetes.io/instance: simple-nifi # Update according to NifiCluster name
39
+
app.kubernetes.io/instance: broken-nifi # Update according to NifiCluster name
40
40
app.kubernetes.io/name: nifi
41
41
ports:
42
42
- name: http
@@ -53,17 +53,17 @@ If you are using an ingress controller, an Ingress could look something like
53
53
apiVersion: networking.k8s.io/v1
54
54
kind: Ingress
55
55
metadata:
56
-
name: simple-nifi-listen-http # Update according to NifiCluster name
56
+
name: broken-nifi-listen-http # Update according to NifiCluster name
57
57
spec:
58
58
rules:
59
-
- host: simple-nifi-listen-http.my.corp # Update to your host
59
+
- host: broken-nifi-listen-http.my.corp # Update to your host
60
60
http:
61
61
paths:
62
62
- pathType: Prefix
63
63
path: /
64
64
backend:
65
65
service:
66
-
name: simple-nifi-listen-http # Update to your Service name
66
+
name: broken-nifi-listen-http # Update to your Service name
67
67
port:
68
68
number: 8042
69
69
----
@@ -78,7 +78,7 @@ Start the `ListenHTTP` processor.
78
78
image:listen-http-2.png[´RouteOnAttribute connected to ListenHTTP processor]
79
79
80
80
The `ListenHTTP` processor should now generate a FlowFile for every incoming HTTP request.
81
-
You can test this by calling `curl --verbose --data '{"hello":"NiFi"}' https://simple-nifi-listen-http.my.corp`, you should get a `HTTP/2 200` response.
81
+
You can test this by calling `curl --verbose --data '{"hello":"NiFi"}' https://broken-nifi-listen-http.my.corp`, you should get a `HTTP/2 200` response.
82
82
83
83
TIP: If you get a `503 Service Temporarily Unavailable`, this probably means your Ingress controller was not able to
84
84
reach your `ListenHTTP` processor. Check that the processor is running and configured correctly.
Copy file name to clipboardExpand all lines: docs/modules/nifi/pages/usage_guide/exposing-processors/tcp.adoc
+3-3Lines changed: 3 additions & 3 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -9,7 +9,7 @@ Stackable doesn't place any restriction on the type of service that can be used
9
9
== Example
10
10
11
11
An example for this is shown below.
12
-
It consists of a NiFi cluster with three nodes called `simple-nifi` and has a processor that listens to a TCP port and forwards lines written into that port as flowfiles.
12
+
It consists of a NiFi cluster with three nodes called `broken-nifi` and has a processor that listens to a TCP port and forwards lines written into that port as flowfiles.
NOTE: The above URL connects to one of the Pods, reachable through the specified Service, therefore scraping metrics produced by that Pod only.
48
-
To scrape metrics from a particular Pod, the FQDN of the Pod and the `headless` Service need to be used. For example: `\https://simple-nifi-node-default-0.simple-nifi-node-default-headless.<namespace>.svc.cluster.local:8443/nifi-api/flow/metrics/prometheus`
48
+
To scrape metrics from a particular Pod, the FQDN of the Pod and the `headless` Service need to be used. For example: `\https://broken-nifi-node-default-0.broken-nifi-node-default-headless.<namespace>.svc.cluster.local:8443/nifi-api/flow/metrics/prometheus`
49
49
50
50
IMPORTANT: If NiFi is configured to do any user authentication, requests to the metrics endpoint must be authenticated and authorized.
0 commit comments