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

[tzulitai]

This is a follow-up to #61, adding the YAML-ized Kinesis ingress / egresses.

---

Usage

• Ingress:

ingress:
  meta:
    type: statefun.kinesis.io/routable-protobuf-ingress
    id: com.mycomp.foo/bar
  spec:
    awsRegion:
      type: specific
      id: us-west-2
    awsCredentials:
      type: basic
      accessKeyId: my_access_key_id
      secretAccessKey: my_secret_access_key
    startupPosition:
      type: earliest
    streams:
      - stream: stream-1
        typeUrl: com.googleapis/com.mycomp.foo.MessageA
        targets:
          - com.mycomp.foo/function-1
          - com.mycomp.foo/function-2
      - stream: topic-2
        typeUrl: com.googleapis/com.mycomp.foo.MessageB
        targets:
          - com.mycomp.foo/function-2
    clientConfigProperties:
      - SocketTimeout: 9999
      - MaxConnections: 15

• Egress:

egress:
  meta:
    type: statefun.kinesis.io/generic-egress
    id: com.mycomp.foo/bar
  spec:
    awsRegion:
      type: custom-endpoint
      endpoint: https://localhost:4567
      id: us-west-1
    awsCredentials:
      type: profile
      profileName: john-doe
      profilePath: /path/to/profile/config
    maxOutstandingRecords: 9999
    clientConfigProperties:
      - ThreadingModel: POOLED
      - ThreadPoolSize: 10

Note: by default, awsRegion, awsCredentials, startupPosition, maxOutstandingRecords, and clientConfigProperties do not need to be specified.

---

Changelog

Important changes are:

• 54cf5a2 Implement runtime classes / providers for the routable protobuf Kinesis ingress

• 001561f Binds the AutoRoutableProtobufRouter for the routable Kinesis ingress in the JsonModule

• ad56622 Binds the new provider for the routable Kinesis ingress

• ba46048 Implements runtime classes / providers for the generic Kinesis egress

• 094dc6c Binds the new provider for the generic Kinesis egress

All other commits are preliminary changes for the above.

[igalshilman]

LGTM.

[tzulitai]

Thanks for the review @igalshilman, merging ...