Re: Re:Re: Re:flinksql 输出到kafka用的fixed的方式 结果都输出到一个topic分区了，这个是什么原因

2020-11-10 文章 leiyanrui 
好的 谢谢哈 



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re:Re: Re:flinksql 输出到kafka用的fixed的方式 结果都输出到一个topic分区了，这个是什么原因

2020-11-10 文章 马阳阳 



这个1.11.0和1.11.1的bug，已经在1.11.2里修复了，可以看下[1]这个issue

[1] 
https://issues.apache.org/jira/browse/FLINK-19285?jql=project%20%3D%20FLINK%20AND%20text%20~%20%22kafka%20partitioner%22














在 2020-11-10 22:26:09，"leiyanrui" <1150693...@qq.com> 写道：
>我的topic分区数是10个，sink的并发是25个 ，按照取余计算的话 也不应该只输出到一个partition的
>
>
>
>--
>Sent from: http://apache-flink.147419.n8.nabble.com/