Hi Soheil,
That feature is actually already internally available.
The only issue is that the functionality is not yet exposed via any public APIs
on the Kafka consumer.
Please see this JIRA here: https://issues.apache.org/jira/browse/FLINK-8190.
I’m not sure of exposing the pattern-based subscri
Sounds like adding a round robin partitioner to the set of readily
available partitioners would make sense.
On Fri, Dec 1, 2017 at 5:16 AM, Tzu-Li (Gordon) Tai
wrote:
> Hi Mike,
>
> The rationale behind implementing the FlinkFixedPartitioner as the default
> is so that each Flink sink partition
