Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-21441

FlinkKinesisProducer does not forward custom endpoint

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Minor
    • Resolution: Unresolved
    • Affects Version/s: 1.12.1, 1.13.0
    • Fix Version/s: None
    • Component/s: Connectors / Kinesis
    • Labels:

      Description

      For the Kinesis connector, between aws.region and aws.endpoint one is required. For FlinkKinesisProducer, however, aws.region is always required.

      However, in this case the aws.endpoint never ends up being used since the code only calls KinesisProducerConfiguration#fromProperties. One would have to set a "KinesisEndpoint" property instead, but this is not a valid property.

      This should be fixed such that a custom endpoint can be used, probably the same goes for the port.

      Also, this is currently being worked around here: https://github.com/apache/flink/blob/master/flink-end-to-end-tests/flink-streaming-kinesis-test/src/main/java/org/apache/flink/streaming/kinesis/test/KinesisExample.java#L70

        Attachments

          Activity

            People

            • Assignee:
              dannycranmer Danny Cranmer
              Reporter:
              airblader Ingo Bürk
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: