Flink消费kafka太慢怎么优化？

来源：11-5 Mock数据之Kafka生产者代码主流程开发

Amourxxxx

2019-09-28

现在kafka四个分区。flink给了2个tasknode，每个8g。流程就是从kafka消费过来，直接用bucketsink当时写出到s3。中间没任何业务逻辑，每秒只能写出500条大概几百k的数据。。这也太慢了，不知道能从哪方面能优化下呢。

写回答

1回答

Michael_PK

2019-09-28

那你需要定位到到底是慢走哪里，是kafka的问题，还是flink消费不行，找到根源才能对症下药

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势，多语言系统化讲解，极速入门Flink

969 学习 · 296 问题

相似问题

回答 1

回答 1

回答 1

回答 1

回答 4