from: statefun-kafka-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaEgressSpec.java"
   contains "import org.apache.flink.statefun.sdk.EgressType;"

from: statefun-kafka-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressSpec.java"
   contains "import org.apache.flink.statefun.sdk.IngressType;"

from: statefun-kafka-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/Constants.java"
   contains "import org.apache.flink.statefun.sdk.EgressType;"

from: statefun-kafka-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressBuilder.java"
   contains "import org.apache.flink.statefun.sdk.core.OptionalProperty;"

from: statefun-kafka-io
to: statefun-sdk-embedded
evidence:
 - file: "statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaEgressBuilder.java"
   contains "import org.apache.flink.statefun.sdk.io.EgressIdentifier;"