[FLINK-16124] YAML-ized Kinesis ingress / egresses#64

Closed

tzulitai wants to merge 11 commits intoapache:masterfrom tzulitai:FLINK-16124-Yaml

+970-25

Commits on Mar 19, 2020

[hotfix] [kafka] Fix raw types in KafkaIngressBuilder
tzulitai
committed
[FLINK-16124] [kinesis] Support building with KinesisIngressDeserializer instances at runtime
tzulitai
committed

Commits on Mar 20, 2020

[hotfix] [core] Selectors.propertiesAt should always parse property values as strings
tzulitai
committed
[FLINK-16124] [core] Parse spec JSON in JsonIngressSpec
tzulitai
committed
[FLINK-16124] [kinesis] Implement runtime RoutableProtobufKinesisSourceProvider
tzulitai
committed
[FLINK-16124] [core] Bind AutoRoutableProtobufRouter for Routable Protobuf Kinesis ingresses
tzulitai
committed
[FLINK-16124] [kinesis] Bind Routable Protobuf Kafka ingress type in KinesisFlinkIOModule
tzulitai
committed
[FLINK-16124] [kinesis] Introduce KinesisEgressRecord protobuf message
tzulitai
committed
[FLINK-16124] [core] Parse spec JSON within JsonEgressSpec
tzulitai
committed
[FLINK-16124] [kinesis] Implement runtime GenericKinesisSinkProvider
tzulitai
committed
[FLINK-16124] [kinesis] Bind Generic Kafka egress type in KinesisFlinkIOModule
tzulitai
committed