Apache Flink-无法将本地Kinesis用于FlinkKinesisConsumer

Question

到目前为止，我已经按照Flink的kinesis连接器记录的说明使用本地Kinesis。

使用非AWS的Kinesis端点进行测试

Properties producerConfig = new Properties();
producerConfig.put(AWSConfigConstants.AWS_REGION, "us-east-1");
producerConfig.put(AWSConfigConstants.AWS_ACCESS_KEY_ID, "aws_access_key_id");
producerConfig.put(AWSConfigConstants.AWS_SECRET_ACCESS_KEY, "aws_secret_access_key");
producerConfig.put(AWSConfigConstants.AWS_ENDPOINT, "http://localhost:4567");

对于Flink生产商，这些说明适用于局部运动（我使用Kinesalite）。

然而，随着消费者弗林克，我得到一个异常aws.region和aws.endpoint未都不允许。但是区域是必需的，这意味着无法覆盖端点。

org.apache.flink.client.program.ProgramInvocationException：导致错误的主要方法：对于FlinkKinesisConsumer，必须在配置中设置AWS区域（'aws.region'）或AWS终端节点（'aws.endpoint'）。

这是连接器中的错误吗？我看到一个相关的PR：https : //github.com/apache/flink/pull/6045。

我在Flink的邮件列表中找到了一种解决方法，但是他们将其描述为生产者而不是消费者的问题，而我却相反（我认为），因此不确定。真是令人困惑。

Answer 1

自从提出这个问题以来，已经取得了一些进展。

提问者将此问题推送到此 jira中，该 jira 被标记为第二个 jira的重复项。

该问题现已解决，并且修复程序适用于 1.10 及更高版本。