[FLINK-21959] Rename statefun.kafka.io/routable-protobuf-ingress => io.statefun.kafka/ingress
diff --git a/docs/content/docs/io-module/apache-kafka.md b/docs/content/docs/io-module/apache-kafka.md
index 007a65e..3f186eb 100644
--- a/docs/content/docs/io-module/apache-kafka.md
+++ b/docs/content/docs/io-module/apache-kafka.md
@@ -3,7 +3,7 @@
weight: 2
type: docs
aliases:
- - /io-module/apache-kafka.html
+- /io-module/apache-kafka.html
---
<!--
Licensed to the Apache Software Foundation (ASF) under one
@@ -44,7 +44,7 @@
ingresses:
- ingress:
meta:
- type: statefun.kafka.io/routable-protobuf-ingress
+ type: io.statefun.kafka/ingress
id: com.example/users
spec:
address: kafka-broker:9092
@@ -53,7 +53,7 @@
type: earliest
topics:
- topic: messages-1
- typeUrl: com.example/User
+ valueType: com.example/User
targets:
- com.example.fns/greeter
```
@@ -134,7 +134,7 @@
egresses:
- egress:
meta:
- type: statefun.kafka.io/generic-egress
+ type: io.statefun.kafka/egress
id: example/output-messages
spec:
address: kafka-broker:9092
@@ -182,7 +182,7 @@
### Writing To Kafka
-Functions write directly to Kafka from their SDK context. See SDK specific documentation for more details.
+Functions write directly to Kafka from their SDK context. See SDK specific documentation for more details.
{{< tabs "writer" >}}
{{< tab "Python" >}}
diff --git a/statefun-e2e-tests/statefun-exactly-once-remote-e2e/src/test/resources/remote-module/module.yaml b/statefun-e2e-tests/statefun-exactly-once-remote-e2e/src/test/resources/remote-module/module.yaml
index 8aca93c..95dbfbd 100644
--- a/statefun-e2e-tests/statefun-exactly-once-remote-e2e/src/test/resources/remote-module/module.yaml
+++ b/statefun-e2e-tests/statefun-exactly-once-remote-e2e/src/test/resources/remote-module/module.yaml
@@ -31,7 +31,7 @@
ingresses:
- ingress:
meta:
- type: statefun.kafka.io/routable-protobuf-ingress
+ type: io.statefun.kafka/ingress
id: org.apache.flink.statefun.e2e.remote/invoke
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 292814d..f302ae2 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: statefun.kafka.io/routable-protobuf-ingress
+ type: io.statefun.kafka/ingress
id: com.mycomp.foo/bar
spec:
address: kafka-broker:9092
diff --git a/statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/kafka/ProtobufKafkaIngressTypes.java b/statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/kafka/ProtobufKafkaIngressTypes.java
index 3e031c2..800746b 100644
--- a/statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/kafka/ProtobufKafkaIngressTypes.java
+++ b/statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/kafka/ProtobufKafkaIngressTypes.java
@@ -28,5 +28,5 @@
new IngressType("statefun.kafka.io", "protobuf-ingress");
public static final IngressType ROUTABLE_PROTOBUF_KAFKA_INGRESS_TYPE =
- new IngressType("statefun.kafka.io", "routable-protobuf-ingress");
+ new IngressType("io.statefun.kafka", "ingress");
}
