开发者社区 问答 正文

请问Flink程序中使用redis,有朋友用过吗?现在我们使用的是原始的Jedis,感觉性能不是特别好,请问有没有更好的解决方案?

转自钉钉群21789141:请问Flink程序中使用redis,有朋友用过吗?现在我们使用的是原始的Jedis,感觉性能不是特别好,请问有没有更好的解决方案?
image

展开
收起
赵慧@ApacheFlink中文社区 2018-10-18 15:42:57 4667 分享 版权
1 条回答
写回答
取消 提交回答
  • JasonLee:RedisSink试一下\
    粗略看了下你这个程序,每次map都新redis连接池。这个也可能是拖慢性能的原因。
    莱昂:把redis连接放到open方法中 用rich函数
    问:业务需求中需要针对kafka一条数据,多次进行redis查询和写入,RedisSink不太符合业务需求

    2019-07-17 23:09:17
    赞同 展开评论