Hi 看起来你经确定了是在写入kafka时过慢导致了高峰期sink反压， 生产环境上1万的tps不算高的，可以先确定下是否是kafka集群写入瓶颈问题，kafka 自带的 perf 脚本可以测试下6个分区的topic写入的能力，测试时数据大小和tpoic配置可以和生产一致，如果是kafka写入瓶颈问题，那就需要增加分区，对应修改flink作业的写入并发。 另外，如果开启exactly-once配置，写入速度会慢一些，没有特别的业务需求可以用at-least-once.
祝好 Leonard > 在 2020年10月13日，19:38，xyq <xiayongquan1...@163.com> 写道： > > kafka
