[FLINK-16398] [kafka] Change all Kafka type strings in tests files accordingly
This closes #48.
diff --git a/statefun-e2e-tests/statefun-routable-kafka-e2e/src/test/resources/routable-kafka-ingress-module/module.yaml b/statefun-e2e-tests/statefun-routable-kafka-e2e/src/test/resources/routable-kafka-ingress-module/module.yaml
index 6e0c7f5..d9f1b5e 100644
--- a/statefun-e2e-tests/statefun-routable-kafka-e2e/src/test/resources/routable-kafka-ingress-module/module.yaml
+++ b/statefun-e2e-tests/statefun-routable-kafka-e2e/src/test/resources/routable-kafka-ingress-module/module.yaml
@@ -20,7 +20,7 @@
ingresses:
- ingress:
meta:
- type: org.apache.flink.statefun.sdk.kafka/routable-protobuf-kafka-connector
+ type: statefun.kafka.io/routable-protobuf-ingress
id: org.apache.flink.statefun.e2e/messages
spec:
address: kafka-broker:9092
diff --git a/statefun-flink/statefun-flink-common/src/test/resources/bar-module/module.yaml b/statefun-flink/statefun-flink-common/src/test/resources/bar-module/module.yaml
index 8959366..5c86a50 100644
--- a/statefun-flink/statefun-flink-common/src/test/resources/bar-module/module.yaml
+++ b/statefun-flink/statefun-flink-common/src/test/resources/bar-module/module.yaml
@@ -42,7 +42,7 @@
ingressess:
- ingress:
meta:
- type: org.apache.flink.statefun.sdk.kafka/protobuf-kafka-connector
+ type: statefun.kafka.io/protobuf-ingress
id: com.mycomp.igal/names
spec:
address: kafka-broker:9092
diff --git a/statefun-flink/statefun-flink-core/src/test/resources/bar-module/module.yaml b/statefun-flink/statefun-flink-core/src/test/resources/bar-module/module.yaml
index 68e68c4..e7afab5 100644
--- a/statefun-flink/statefun-flink-core/src/test/resources/bar-module/module.yaml
+++ b/statefun-flink/statefun-flink-core/src/test/resources/bar-module/module.yaml
@@ -46,7 +46,7 @@
ingresses:
- ingress:
meta:
- type: org.apache.flink.statefun.sdk.kafka/protobuf-kafka-connector
+ type: statefun.kafka.io/protobuf-ingress
id: com.mycomp.igal/names
spec:
address: kafka-broker:9092
@@ -59,7 +59,7 @@
egresses:
- egress:
meta:
- type: org.apache.flink.statefun.sdk.kafka/generic-kafka-egress
+ type: statefun.kafka.io/generic-egress
id: com.mycomp.foo/bar
spec:
address: kafka-broker:9092
diff --git a/statefun-flink/statefun-flink-io-bundle/src/test/resources/generic-kafka-egress.yaml b/statefun-flink/statefun-flink-io-bundle/src/test/resources/generic-kafka-egress.yaml
index 4e91319..d8e539e 100644
--- a/statefun-flink/statefun-flink-io-bundle/src/test/resources/generic-kafka-egress.yaml
+++ b/statefun-flink/statefun-flink-io-bundle/src/test/resources/generic-kafka-egress.yaml
@@ -15,7 +15,7 @@
egress:
meta:
- type: org.apache.flink.statefun.sdk.kafka/generic-kafka-egress
+ type: statefun.kafka.io/generic-egress
id: com.mycomp.foo/bar
spec:
address: kafka-broker:9092
diff --git a/statefun-flink/statefun-flink-io-bundle/src/test/resources/protobuf-kafka-ingress.yaml b/statefun-flink/statefun-flink-io-bundle/src/test/resources/protobuf-kafka-ingress.yaml
index db1c910..0a8ee24 100644
--- a/statefun-flink/statefun-flink-io-bundle/src/test/resources/protobuf-kafka-ingress.yaml
+++ b/statefun-flink/statefun-flink-io-bundle/src/test/resources/protobuf-kafka-ingress.yaml
@@ -15,7 +15,7 @@
ingress:
meta:
- type: org.apache.flink.statefun.sdk.kafka/protobuf-kafka-connector
+ type: statefun.kafka.io/protobuf-ingress
id: com.mycomp.igal/names
spec:
address: kafka-broker:9092
diff --git a/statefun-flink/statefun-flink-io-bundle/src/test/resources/routable-protobuf-kafka-ingress.yaml b/statefun-flink/statefun-flink-io-bundle/src/test/resources/routable-protobuf-kafka-ingress.yaml
index 3d20221..292814d 100644
--- a/statefun-flink/statefun-flink-io-bundle/src/test/resources/routable-protobuf-kafka-ingress.yaml
+++ b/statefun-flink/statefun-flink-io-bundle/src/test/resources/routable-protobuf-kafka-ingress.yaml
@@ -15,7 +15,7 @@
ingress:
meta:
- type: org.apache.flink.statefun.sdk.kafka/routable-protobuf-kafka-connector
+ type: statefun.kafka.io/routable-protobuf-ingress
id: com.mycomp.foo/bar
spec:
address: kafka-broker:9092
