This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.
from e2305e8 [FLINK-16274] Consolidate constants for Kafka bootstrap
server configuration
add 14e264f [FLINK-16123] [e2e] Add statefun-routable-kafka-e2e E2E test
module
add 1eabdfb [FLINK-16123] Add RoutableKafkaVerificationModule application
for E2E testing
add 9babd73 [FLINK-16123] Support adding classpath files to app image
build context in StatefulFunctionsAppContainers
new 1fe23c0 [FLINK-16123] [e2e] Add RoutableKafkaE2E
new 1df8b49 [hotfix] Fix some last dangling incorrect mentions of *ITCase
new fb88505 [FLINK-16395] [legal] Add OkHttp to NOTICE of
statefun-flink-distribution
new 1bfd242 [FLINK-16396] [kafka] Add Protobuf message for YAML-ized
Kafka egress
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
statefun-e2e-tests/pom.xml | 3 +-
.../e2e/common/StatefulFunctionsAppContainers.java | 32 ++++-
.../pom.xml | 10 +-
.../statefun/e2e/routablekafka}/Constants.java | 20 +--
.../e2e/routablekafka/FnSelfAddressTagger.java | 56 ++++++++
.../flink/statefun/e2e/routablekafka/KafkaIO.java | 58 +++++++++
.../RoutableKafkaVerificationModule.java} | 39 ++----
.../protobuf/routable-kafka-verification.proto | 39 +++---
.../e2e/routablekafka/RoutableKafkaE2E.java | 142 +++++++++++++++++++++
.../src/test/resources/Dockerfile | 5 +-
.../src/test/resources/log4j.properties | 0
.../routable-kafka-ingress-module/module.yaml | 39 ++++++
.../flink/statefun/e2e/sanity/Constants.java | 9 +-
.../src/main/resources/META-INF/NOTICE | 1 +
.../src/main/protobuf/kafka-egress.proto | 18 +--
15 files changed, 376 insertions(+), 95 deletions(-)
copy statefun-e2e-tests/{statefun-sanity-e2e =>
statefun-routable-kafka-e2e}/pom.xml (92%)
copy
statefun-e2e-tests/{statefun-sanity-e2e/src/main/java/org/apache/flink/statefun/e2e/sanity
=>
statefun-routable-kafka-e2e/src/main/java/org/apache/flink/statefun/e2e/routablekafka}/Constants.java
(57%)
create mode 100644
statefun-e2e-tests/statefun-routable-kafka-e2e/src/main/java/org/apache/flink/statefun/e2e/routablekafka/FnSelfAddressTagger.java
create mode 100644
statefun-e2e-tests/statefun-routable-kafka-e2e/src/main/java/org/apache/flink/statefun/e2e/routablekafka/KafkaIO.java
copy
statefun-e2e-tests/{statefun-sanity-e2e/src/main/java/org/apache/flink/statefun/e2e/sanity/SanityVerificationModule.java
=>
statefun-routable-kafka-e2e/src/main/java/org/apache/flink/statefun/e2e/routablekafka/RoutableKafkaVerificationModule.java}
(54%)
copy
statefun-flink/statefun-flink-core/src/main/protobuf/stateful-functions.proto
=>
statefun-e2e-tests/statefun-routable-kafka-e2e/src/main/protobuf/routable-kafka-verification.proto
(65%)
create mode 100644
statefun-e2e-tests/statefun-routable-kafka-e2e/src/test/java/org/apache/flink/statefun/e2e/routablekafka/RoutableKafkaE2E.java
copy statefun-e2e-tests/{statefun-sanity-e2e =>
statefun-routable-kafka-e2e}/src/test/resources/Dockerfile (78%)
copy statefun-e2e-tests/{statefun-sanity-e2e =>
statefun-routable-kafka-e2e}/src/test/resources/log4j.properties (100%)
create mode 100644
statefun-e2e-tests/statefun-routable-kafka-e2e/src/test/resources/routable-kafka-ingress-module/module.yaml
copy
statefun-examples/statefun-greeter-example/src/main/protobuf/greeter.proto =>
statefun-flink/statefun-flink-io/src/main/protobuf/kafka-egress.proto (77%)
