Looking at the doc https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kinesis.html "When the number of shards is larger than the parallelism of the consumer, then each consumer subtask can subscribe to multiple shards; otherwise if the number of shards is smaller than the parallelism of the consumer, then some consumer subtasks will simply be idle and wait until it gets assigned new shards"
I have the *same number of shards as the configured parallelism*. Seems though a task is grabbing multiple shards while others are idle. is that an expected behavior? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
