[jira] [Created] (FLINK-11501) Add a ratelimiting feature to the FlinkKafkaConsumer

Lakshmi Rao created FLINK-11501: --- Summary: Add a ratelimiting feature to the FlinkKafkaConsumer Key: FLINK-11501 URL: https://issues.apache.org/jira/browse/FLINK-11501 Project: Flink Issue Type

[jira] [Created] (FLINK-10171) Allow for assemblePartPath override in the BucketingSink

Lakshmi Rao created FLINK-10171: --- Summary: Allow for assemblePartPath override in the BucketingSink Key: FLINK-10171 URL: https://issues.apache.org/jira/browse/FLINK-10171 Project: Flink Issue

[jira] [Created] (FLINK-9899) Add more metrics to the Kinesis source connector

Lakshmi Rao created FLINK-9899: -- Summary: Add more metrics to the Kinesis source connector Key: FLINK-9899 URL: https://issues.apache.org/jira/browse/FLINK-9899 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-9897) Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops

Lakshmi Rao created FLINK-9897: -- Summary: Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops Key: FLINK-9897 URL: https://issues.apache.org/jira/browse/FLINK-989

[jira] [Created] (FLINK-9692) Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis

Lakshmi Rao created FLINK-9692: -- Summary: Adapt maxRecords parameter in the getRecords call to optimize bytes read from Kinesis Key: FLINK-9692 URL: https://issues.apache.org/jira/browse/FLINK-9692 Proj

[jira] [Created] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis

Lakshmi Rao created FLINK-9691: -- Summary: Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis Key: FLINK-9691 URL: https://issues.apache.org/jira/browse/FLINK-9691 Proje

[jira] [Created] (FLINK-9118) Support a time based rollover of part file in Bucketing Sink

Lakshmi Rao created FLINK-9118: -- Summary: Support a time based rollover of part file in Bucketing Sink Key: FLINK-9118 URL: https://issues.apache.org/jira/browse/FLINK-9118 Project: Flink Issue

[jira] [Created] (FLINK-9115) Support addition of part suffix in BucketingSink

Lakshmi Rao created FLINK-9115: -- Summary: Support addition of part suffix in BucketingSink Key: FLINK-9115 URL: https://issues.apache.org/jira/browse/FLINK-9115 Project: Flink Issue Type: Improv