Flink消费kafka太慢怎么优化？
现在kafka四个分区。flink给了2个tasknode，每个8g。流程就是从kafka消费过来，直接用bucketsink当时写出到s3。中间没任何业务逻辑，每秒只能写出500条大概几百k的数据。。这也太慢了，不知道能从哪方面能优化下呢。
2755
收起
正在回答 回答被采纳积分+3
1回答
Michael_PK
2019-09-28 07:13:39
相似问题
sparkstreming消费kafka算一个消费者吗？
761
0
5
kafka如何保证每条消息只被消费一次
6891
0
4
如何保证kafka消费的顺序呢？
642
0
2
關於流式處理
398
1
5
登录后可查看更多问答，登录/注册
