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
8686
8787echo " Install KafkaCluster from kafka.yaml"
8888# tag::install-kafka[]
89- kubectl apply -f kafka.yaml
89+ kubectl apply --server-side - f kafka.yaml
9090# end::install-kafka[]
9191
9292sleep 15
@@ -99,7 +99,7 @@ kubectl rollout status --watch --timeout=5m statefulset/simple-kafka-broker-defa
9999echo " Starting port-forwarding of port 9092"
100100# shellcheck disable=2069 # we want all output to be blackholed
101101# 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 &
103103# end::port-forwarding[]
104104PORT_FORWARD_PID=$!
105105# 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
114114
115115echo " Writing test data"
116116# 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
118118# end::kcat-write-data[]
119119
120120echo " Reading test data"
121121# 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
123123# end::kcat-read-data[]
124124
125125echo " 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
8686
8787echo " Install KafkaCluster from kafka.yaml"
8888# tag::install-kafka[]
89- kubectl apply -f kafka.yaml
89+ kubectl apply --server-side - f kafka.yaml
9090# end::install-kafka[]
9191
9292sleep 15
@@ -99,7 +99,7 @@ kubectl rollout status --watch --timeout=5m statefulset/simple-kafka-broker-defa
9999echo " Starting port-forwarding of port 9092"
100100# shellcheck disable=2069 # we want all output to be blackholed
101101# 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 &
103103# end::port-forwarding[]
104104PORT_FORWARD_PID=$!
105105# 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
114114
115115echo " Writing test data"
116116# 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
118118# end::kcat-write-data[]
119119
120120echo " Reading test data"
121121# 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
123123# end::kcat-read-data[]
124124
125125echo " Check contents"
Original file line number Diff line number Diff line change 11---
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+ ---
210apiVersion : kafka.stackable.tech/v1alpha1
311kind : KafkaCluster
412metadata :
1220 zookeeperConfigMapName : simple-kafka-znode
1321 brokers :
1422 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
1725 roleGroups :
1826 default :
1927 replicas : 3
You can’t perform that action at this time.
0 commit comments