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 1bfd242 [FLINK-16396] [kafka] Add Protobuf message for YAML-ized Kafka egress add 397d6ad [FLINK-16391] [http] Add delayed and egress messages to request-reply protocol add 1814e4e [FLINK-16396] [kafka] Rename KafkaSpecJsonParser to KafkaIngressSpecJsonParser add fcbd346 [FLINK-16396] Support binding JSON egress specs in JsonModule add 615b373 [hotfix] Remove unused foo-module test resource add 5b7703c [FLINK-16396] [minor] Support longAt in Selectors add b342227 [FLINK-16396] [kafka] Add GenericKafkaSinkProvider add 6620bd5 [FLINK-16396] [kafka] Bind GenericKafkaSinkProvider in KafkaFlinkIoModule add 3cfae08 [hotfix] Refactor YAML loading utility method as test utils No new revisions were added by this update. Summary of changes: .../statefun/flink/common/json/Selectors.java | 8 ++ .../statefun/flink/common/json/SelectorsTest.java | 10 ++ .../statefun/flink/core/jsonmodule/JsonModule.java | 30 ++++++ .../statefun/flink/core/jsonmodule/Pointers.java | 6 ++ .../flink/core/reqreply/RequestReplyFunction.java | 34 ++++++- .../src/main/protobuf/http-function.proto | 25 +++++ .../flink/core/jsonmodule/JsonModuleTest.java | 13 +++ .../core/reqreply/RequestReplyFunctionTest.java | 62 ++++++++++++- .../src/test/resources/bar-module/module.yaml | 12 +++ .../io/kafka/GenericKafkaEgressSerializer.java | 65 +++++++++++++ .../flink/io/kafka/GenericKafkaSinkProvider.java | 102 +++++++++++++++++++++ .../flink/io/kafka/KafkaEgressSpecJsonParser.java | 83 +++++++++++++++++ .../flink/io/kafka/KafkaFlinkIoModule.java | 2 + ...Parser.java => KafkaIngressSpecJsonParser.java} | 4 +- .../io/kafka/ProtobufKafkaSourceProvider.java | 14 +-- .../kafka/RoutableProtobufKafkaSourceProvider.java | 12 +-- .../io/kafka/GenericKafkaSinkProviderTest.java | 49 ++++++++++ .../io/kafka/ProtobufKafkaSourceProviderTest.java | 18 +--- .../RoutableProtobufKafkaSourceProviderTest.java | 19 +--- .../statefun/flink/io/testutils/YamlUtils.java} | 43 +++------ .../src/test/resources/generic-kafka-egress.yaml} | 18 ++-- .../statefun/flink/io/kafka/KafkaEgressTypes.java | 18 ++-- .../{JsonIngressSpec.java => JsonEgressSpec.java} | 19 ++-- .../statefun/sdk/kafka/KafkaEgressBuilder.java | 2 +- 24 files changed, 557 insertions(+), 111 deletions(-) create mode 100644 statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/GenericKafkaEgressSerializer.java create mode 100644 statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/GenericKafkaSinkProvider.java create mode 100644 statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/KafkaEgressSpecJsonParser.java rename statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/{KafkaSpecJsonParser.java => KafkaIngressSpecJsonParser.java} (99%) create mode 100644 statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/kafka/GenericKafkaSinkProviderTest.java copy statefun-flink/{statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/FlinkValueAccessor.java => statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/testutils/YamlUtils.java} (55%) rename statefun-flink/{statefun-flink-core/src/test/resources/foo-module/module.yaml => statefun-flink-io-bundle/src/test/resources/generic-kafka-egress.yaml} (75%) copy statefun-examples/statefun-greeter-example/src/main/protobuf/greeter.proto => statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/kafka/KafkaEgressTypes.java (72%) copy statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/spi/{JsonIngressSpec.java => JsonEgressSpec.java} (73%)