File tree Expand file tree Collapse file tree
hoptimator-k8s/src/test/java/com/linkedin/hoptimator/k8s/status
hoptimator-kafka/src/test/resources
hoptimator-logical/src/test/resources Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -76,7 +76,7 @@ undeploy-flink:
7676
7777deploy-kafka : deploy deploy-flink
7878 kubectl create namespace kafka || echo " skipping"
79- kubectl apply -f " https://strimzi.io/install/latest? namespace= kafka" -n kafka
79+ curl -sL " https://github.com/ strimzi/strimzi-kafka-operator/releases/download/1.0.0/strimzi-cluster-operator-1.0.0.yaml " | sed ' s/ namespace: myproject/namespace: kafka/g ' | kubectl apply -f - -n kafka
8080 sleep 10 # avoid kubectl race condition
8181 kubectl wait --for=condition=Established=True crds/kafkas.kafka.strimzi.io
8282 kubectl apply -f ./deploy/samples/kafkadb.yaml
@@ -89,7 +89,7 @@ undeploy-kafka:
8989 kubectl delete kafkatopic.kafka.strimzi.io --all || echo " skipping"
9090 kubectl delete strimzi -n kafka --all || echo " skipping"
9191 kubectl delete pvc -l strimzi.io/name=one-kafka -n kafka || echo " skipping"
92- kubectl delete -f " https://strimzi.io/install/latest? namespace= kafka" -n kafka || echo " skipping"
92+ curl -sL " https://github.com/ strimzi/strimzi-kafka-operator/releases/download/1.0.0/strimzi-cluster-operator-1.0.0.yaml " | sed ' s/ namespace: myproject/namespace: kafka/g ' | kubectl delete -f - -n kafka || echo " skipping"
9393 kubectl delete -f ./deploy/samples/kafkadb.yaml || echo " skipping"
9494 kubectl delete namespace kafka || echo " skipping"
9595
Original file line number Diff line number Diff line change 1515# Based on examples at:
1616# https://github.com/strimzi/strimzi-kafka-operator/blob/main/examples/kafka
1717
18- apiVersion : kafka.strimzi.io/v1beta2
18+ apiVersion : kafka.strimzi.io/v1
1919kind : KafkaNodePool
2020metadata :
2121 name : controller
3434 kraftMetadata : shared
3535---
3636
37- apiVersion : kafka.strimzi.io/v1beta2
37+ apiVersion : kafka.strimzi.io/v1
3838kind : KafkaNodePool
3939metadata :
4040 name : broker
5353 kraftMetadata : shared
5454---
5555
56- apiVersion : kafka.strimzi.io/v1beta2
56+ apiVersion : kafka.strimzi.io/v1
5757kind : Kafka
5858metadata :
5959 name : one
Original file line number Diff line number Diff line change 1717 databases :
1818 - kafka-database
1919 yaml : |
20- apiVersion: kafka.strimzi.io/v1beta2
20+ apiVersion: kafka.strimzi.io/v1
2121 kind: KafkaTopic
2222 metadata:
2323 name: {{name}}
4242
4343 ---
4444
45- apiVersion : kafka.strimzi.io/v1beta2
45+ apiVersion : kafka.strimzi.io/v1
4646kind : KafkaTopic
4747metadata :
4848 name : kafka-database-existing-topic-1
5858
5959---
6060
61- apiVersion : kafka.strimzi.io/v1beta2
61+ apiVersion : kafka.strimzi.io/v1
6262kind : KafkaTopic
6363metadata :
6464 name : kafka-database-existing-topic-2
Original file line number Diff line number Diff line change @@ -175,7 +175,7 @@ spec:
175175 databases:
176176 - kafka-database
177177 yaml: |
178- apiVersion: kafka.strimzi.io/v1beta2
178+ apiVersion: kafka.strimzi.io/v1
179179 kind: KafkaTopic
180180 metadata:
181181 name: {{name}}
Original file line number Diff line number Diff line change @@ -168,7 +168,7 @@ spec:
168168 methods:
169169 - Scan
170170 yaml: |
171- apiVersion: kafka.strimzi.io/v1beta2
171+ apiVersion: kafka.strimzi.io/v1
172172 kind: KafkaTopic
173173 metadata:
174174 name: {{name}}
Original file line number Diff line number Diff line change 5050 databases : [ kafka-database ]
5151 methods : [ Scan, Modify ]
5252 yaml : |
53- apiVersion: kafka.strimzi.io/v1beta2
53+ apiVersion: kafka.strimzi.io/v1
5454 kind: KafkaTopic
5555 metadata:
5656 name: {{name}}
Original file line number Diff line number Diff line change @@ -65,7 +65,7 @@ public class K8sPipelineElementStatusEstimatorTest {
6565 "apiVersion: foo.org/v1beta1\n " + "kind: FakeJob\n " + "metadata:\n " + " name: fake-job-name\n " + "spec:\n "
6666 + " deploymentName: fake-deployment\n " + " job:\n " + " entryClass: com.runner.FakeRunner" ;
6767 private static final String FAKE_KAFKA_TOPIC_SPEC =
68- "apiVersion: kafka.strimzi.io/v1beta2 \n " + "kind: KafkaTopic\n " + "metadata:\n " + " name: fake-kafka-topic\n "
68+ "apiVersion: kafka.strimzi.io/v1 \n " + "kind: KafkaTopic\n " + "metadata:\n " + " name: fake-kafka-topic\n "
6969 + " labels:\n " + " strimzi.io/cluster: one\n " + "spec:\n " + " topicName: existing-topic-1\n "
7070 + " partitions: 1" ;
7171
Original file line number Diff line number Diff line change 2222 flink.app.type: 'BEAM'
2323 flink.app.name: 'hoptimator-flink-runner'
2424---
25- apiVersion: kafka.strimzi.io/v1beta2
25+ apiVersion: kafka.strimzi.io/v1
2626kind: KafkaTopic
2727metadata:
2828 name: kafka-database-existing-topic-1
3636 retention.ms: 7200000
3737 segment.bytes: 1073741824
3838---
39- apiVersion: kafka.strimzi.io/v1beta2
39+ apiVersion: kafka.strimzi.io/v1
4040kind: KafkaTopic
4141metadata:
4242 name: kafka-database-existing-topic-2
Original file line number Diff line number Diff line change 33
44# Verify create table plan — !specify previews the KafkaTopic YAML without executing
55create or replace table "KAFKA"."create-table-test" ("KEY" VARCHAR, "VALUE" BINARY) WITH ("kafka.partitions" '5');
6- apiVersion: kafka.strimzi.io/v1beta2
6+ apiVersion: kafka.strimzi.io/v1
77kind: KafkaTopic
88metadata:
99 name: kafka-database-create-table-test
5555 upgradeMode: stateless
5656 state: running
5757---
58- apiVersion: kafka.strimzi.io/v1beta2
58+ apiVersion: kafka.strimzi.io/v1
5959kind: KafkaTopic
6060metadata:
6161 name: kafka-database-create-table-test
6969 retention.ms: 7200000
7070 segment.bytes: 1073741824
7171---
72- apiVersion: kafka.strimzi.io/v1beta2
72+ apiVersion: kafka.strimzi.io/v1
7373kind: KafkaTopic
7474metadata:
7575 name: kafka-database-existing-topic-2
Original file line number Diff line number Diff line change 4141 upgradeMode: stateless
4242 state: running
4343---
44- apiVersion: kafka.strimzi.io/v1beta2
44+ apiVersion: kafka.strimzi.io/v1
4545kind: KafkaTopic
4646metadata:
4747 name: kafka-database-existing-topic-1
5555 retention.ms: 7200000
5656 segment.bytes: 1073741824
5757---
58- apiVersion: kafka.strimzi.io/v1beta2
58+ apiVersion: kafka.strimzi.io/v1
5959kind: KafkaTopic
6060metadata:
6161 name: kafka-database-existing-topic-2
You can’t perform that action at this time.
0 commit comments