File tree Expand file tree Collapse file tree 3 files changed +18
-10
lines changed
docs/modules/kafka/examples/getting_started Expand file tree Collapse file tree 3 files changed +18
-10
lines changed Original file line number Diff line number Diff line change @@ -86,7 +86,7 @@ kubectl rollout status --watch --timeout=5m statefulset/simple-zk-server-default
86
86
87
87
echo " Install KafkaCluster from kafka.yaml"
88
88
# tag::install-kafka[]
89
- kubectl apply -f kafka.yaml
89
+ kubectl apply --server-side - f kafka.yaml
90
90
# end::install-kafka[]
91
91
92
92
sleep 15
@@ -99,7 +99,7 @@ kubectl rollout status --watch --timeout=5m statefulset/simple-kafka-broker-defa
99
99
echo " Starting port-forwarding of port 9092"
100
100
# shellcheck disable=2069 # we want all output to be blackholed
101
101
# tag::port-forwarding[]
102
- kubectl port-forward svc/simple-kafka 9092 2>&1 > /dev/null &
102
+ kubectl port-forward svc/simple-kafka-broker-default-bootstrap 9092 2>&1 > /dev/null &
103
103
# end::port-forwarding[]
104
104
PORT_FORWARD_PID=$!
105
105
# shellcheck disable=2064 # we want the PID evaluated now, not at the time the trap is
@@ -114,12 +114,12 @@ echo "some test data" > data
114
114
115
115
echo " Writing test data"
116
116
# tag::kcat-write-data[]
117
- kafkacat -b localhost:9092 -t test-data-topic -P data
117
+ kcat -b localhost:9092 -t test-data-topic -P data
118
118
# end::kcat-write-data[]
119
119
120
120
echo " Reading test data"
121
121
# tag::kcat-read-data[]
122
- kafkacat -b localhost:9092 -t test-data-topic -C -e > read-data.out
122
+ kcat -b localhost:9092 -t test-data-topic -C -e > read-data.out
123
123
# end::kcat-read-data[]
124
124
125
125
echo " Check contents"
Original file line number Diff line number Diff line change @@ -86,7 +86,7 @@ kubectl rollout status --watch --timeout=5m statefulset/simple-zk-server-default
86
86
87
87
echo " Install KafkaCluster from kafka.yaml"
88
88
# tag::install-kafka[]
89
- kubectl apply -f kafka.yaml
89
+ kubectl apply --server-side - f kafka.yaml
90
90
# end::install-kafka[]
91
91
92
92
sleep 15
@@ -99,7 +99,7 @@ kubectl rollout status --watch --timeout=5m statefulset/simple-kafka-broker-defa
99
99
echo " Starting port-forwarding of port 9092"
100
100
# shellcheck disable=2069 # we want all output to be blackholed
101
101
# tag::port-forwarding[]
102
- kubectl port-forward svc/simple-kafka 9092 2>&1 > /dev/null &
102
+ kubectl port-forward svc/simple-kafka-broker-default-bootstrap 9092 2>&1 > /dev/null &
103
103
# end::port-forwarding[]
104
104
PORT_FORWARD_PID=$!
105
105
# shellcheck disable=2064 # we want the PID evaluated now, not at the time the trap is
@@ -114,12 +114,12 @@ echo "some test data" > data
114
114
115
115
echo " Writing test data"
116
116
# tag::kcat-write-data[]
117
- kafkacat -b localhost:9092 -t test-data-topic -P data
117
+ kcat -b localhost:9092 -t test-data-topic -P data
118
118
# end::kcat-write-data[]
119
119
120
120
echo " Reading test data"
121
121
# tag::kcat-read-data[]
122
- kafkacat -b localhost:9092 -t test-data-topic -C -e > read-data.out
122
+ kcat -b localhost:9092 -t test-data-topic -C -e > read-data.out
123
123
# end::kcat-read-data[]
124
124
125
125
echo " Check contents"
Original file line number Diff line number Diff line change 1
1
---
2
+ apiVersion : listeners.stackable.tech/v1alpha1
3
+ kind : ListenerClass
4
+ metadata :
5
+ name : external-unstable-ip
6
+ spec :
7
+ serviceType : NodePort
8
+ preferredAddressType : IP
9
+ ---
2
10
apiVersion : kafka.stackable.tech/v1alpha1
3
11
kind : KafkaCluster
4
12
metadata :
12
20
zookeeperConfigMapName : simple-kafka-znode
13
21
brokers :
14
22
config :
15
- bootstrapListenerClass : external-unstable # This exposes your Stacklet outside of Kubernetes. Remove this property if this is not desired
16
- brokerListenerClass : external-unstable # This exposes your Stacklet outside of Kubernetes. Remove this property if this is not desired
23
+ bootstrapListenerClass : external-unstable-ip # This exposes your Stacklet outside of Kubernetes. Remove this property if this is not desired
24
+ brokerListenerClass : external-unstable-ip # This exposes your Stacklet outside of Kubernetes. Remove this property if this is not desired
17
25
roleGroups :
18
26
default :
19
27
replicas : 3
You can’t perform that action at this time.
0 commit comments