Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5108
After some offline discussion with @aljoscha, we decided to leave the
`FlinkFixedPartitioner` as it is, and close this PR. I personally also agree
with this mainly due to:
> However, if we were to re-visit the semantics of the fixed partitioner,
it could be that it actually makes more sense that the fixed partitioner
switches partition on scaling out Kafka.
Since 9ed9b68 is actually part of Flink 1.3 already, and we haven't
received any complaints so far on the changed semantics, it definitely is
arguable that we don't really need to apply this PR fix at all.
---
