shizhengchao commented on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1057622360
@PatrickRen I got through testing that the RoundRobinPartitioner built into kafka does not work either, that is it can't distribute the writes to all partitions equally, due to abortForNewBatch. So this has to be redesigned in the high version of kafka client -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
